def create_thumbnail()

in usecases/image-processing/dags/2.0/image_processing.py [0:0]

• 8 lines of code
• 1 McCabe index (conditional complexity)

def create_thumbnail(ds, **kwargs): 

    hook = AwsLambdaHook('LAMBDA_FN_NAME', #LAMBDA_FN_NAME
                            log_type='None',qualifier='$LATEST',
                            invocation_type='RequestResponse',
                            config=None,aws_conn_id='aws_default')

    response_1 = hook.invoke_lambda(payload=json.dumps(kwargs['dag_run'].conf))
    payload = json.loads(response_1['Payload'].read().decode())
    kwargs['ti'].xcom_push(key="ThumbnailDetails", value=payload)