`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

Get the underlying boto3 Appflow client (cached).

run_flow(flow_name, poll_interval=20, wait_for_completion=True)[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

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[mypy_boto3_appflow.type_defs.TaskTypeDef]) – 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