airflow.providers.amazon.aws.hooks.appflow

Module Contents

Classes

AppflowHook

Interact with Amazon Appflow.
class airflow.providers.amazon.aws.hooks.appflow.AppflowHook(*args, **kwargs)[source]

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

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

conn()[source]

Get the underlying boto3 Appflow client (cached).

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

Was this entry helpful?