FlyteOperator
FlyteLaunch Flyte executions from within Airflow.
Access Instructions
Install the Flyte provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
flyte_conn_idRequired. The connection to Flyte setup, containing metadata.
projectOptional. The project to connect to.
domainOptional. The domain to connect to.
launchplan_nameOptional. The name of the launchplan to trigger.
task_nameOptional. The name of the task to trigger.
max_parallelismOptional. The maximum number of parallel executions to allow.
raw_output_data_configOptional. Location of offloaded data for things like S3, etc.
kubernetes_service_accountOptional. The Kubernetes service account to use.
oauth2_clientOptional. The OAuth2 client to use.
labelsOptional. Custom labels to be applied to the execution resource.
annotationsOptional. Custom annotations to be applied to the execution resource.
secretsOptional. Custom secrets to be applied to the execution resource.
notificationsOptional. List of notifications to be applied to the execution resource.
disable_notificationsOptional. Whether to disable notifications.
versionOptional. The version of the launchplan/task to trigger.
inputsOptional. The inputs to the launchplan/task.
Documentation
Launch Flyte executions from within Airflow.
See also
For more information on how to use this operator, take a look at the guide: howto/operator:AirflowFlyteOperator