`airflow.providers.amazon.aws.hooks.appflow`¶

Module Contents¶

Interact with Amazon AppFlow.

class airflow.providers.amazon.aws.hooks.appflow.AppflowHook(*args, **kwargs)[source]¶

Interact with Amazon AppFlow.

Provide thin wrapper around boto3.client("appflow").

Additional arguments (such as aws_conn_id) may be specified and are passed down to the underlying AwsBaseHook.

See also

run_flow(flow_name, poll_interval=20, wait_for_completion=True, max_attempts=60)[source]¶

Execute an AppFlow run.

Parameters

flow_name (str) – The flow name
poll_interval (int) – Time (seconds) to wait between two consecutive calls to check the run status
wait_for_completion (bool) – whether to wait for the run to end to return
max_attempts (int) – the number of polls to do before timing out/returning a failure.

Returns

The run execution ID

Return type

str

update_flow_filter(flow_name, filter_tasks, set_trigger_ondemand=False)[source]¶

Update the flow task filter; all filters will be removed if an empty array is passed to filter_tasks.

Parameters

flow_name (str) – The flow name
filter_tasks – List flow tasks to be added
set_trigger_ondemand (bool) – If True, set the trigger to on-demand; otherwise, keep the trigger as is

Returns

None

Return type

None