"""Example Lambda Task.""" from hooks.lambda_hook import OrchLambdaHook from tasks.example_lambda import helpers def invoke_example_lambda_callback(dag_run, **kwargs): """Invoke an example lambda.""" event = helpers.get_event_from_params(dag_run, **kwargs) hook = OrchLambdaHook('foo-bar-handler') response = hook.invoke_lambda(event.to_json()) if not response.function_response.succeeded: raise Exception(response.error_message)