Statements (137)
| Predicate | Object |
|---|---|
| gptkbp:instanceOf |
gptkb:class
gptkb:software |
| gptkbp:alternativeName |
AirflowOperator
Airflow_Executor Apache_Airflow_Operator PythonOperator |
| gptkbp:canBe |
gptkb:TaskFlow_API
gptkb:XCom True airflow.cfg |
| gptkbp:definedIn |
airflow.operators.python module
|
| gptkbp:documentation |
https://airflow.apache.org/docs/apache-airflow/stable/howto/operator/python.html
https://airflow.apache.org/docs/ https://airflow.apache.org/docs/apache-airflow/stable/concepts/operators.html |
| gptkbp:executedBy |
Task
DAG tasks |
| gptkbp:hasType |
gptkb:BashOperator
gptkb:BigQueryCheckOperator gptkb:BigQueryIntervalCheckOperator gptkb:BigQueryOperator gptkb:BigQueryToGCSOperator gptkb:BigQueryValueCheckOperator gptkb:BranchPythonOperator gptkb:DockerOperator gptkb:DummyOperator gptkb:EmailOperator gptkb:ExternalTaskSensor gptkb:FileSensor gptkb:HttpSensor gptkb:KubernetesPodOperator gptkb:MySqlOperator gptkb:PostgresOperator gptkb:S3FileTransformOperator gptkb:S3KeySensor gptkb:SlackAPIOperator gptkb:SnowflakeOperator gptkb:TimeSensor gptkb:TriggerDagRunOperator gptkb:CeleryExecutor gptkb:KubernetesExecutor gptkb:SequentialExecutor gptkb:SlackAPIPostOperator detector LocalExecutor Airflow Operator DaskExecutor BigQueryToBigQueryOperator DataProcHadoopOperator DataProcHiveOperator DataProcJobBaseOperator DataProcPigOperator DataProcPySparkOperator DataProcSparkOperator DatabricksSubmitRunOperator DataflowTemplateOperator EmrAddStepsOperator EmrCreateJobFlowOperator EmrTerminateJobFlowOperator FTPHook FTPOperator FTPSensor GCSDeleteOperator GCSObjectExistenceSensor GCSObjectsWithPrefixExistenceSensor GCSSensor GCSToBigQueryOperator GCSToGCSOperator GCSToS3Operator GCSUploadSessionCompleteSensor HdfsSensor HiveOperator HivePartitionSensor HttpOperator NamedHivePartitionSensor PrestoOperator PythonVirtualenvOperator RedshiftToS3Operator S3CopyObjectOperator S3CreateBucketOperator S3DeleteBucketOperator S3DeleteObjectsOperator S3ListOperator S3PrefixSensor S3Sensor S3ToGCSOperator S3ToRedshiftOperator S3ToS3Operator SFTPOperator SFTPSensor SimpleHttpOperator SqlOperator SqlSensor SubDagOperator TimeDeltaSensor |
| gptkbp:inheritsFrom |
gptkb:BaseOperator
|
| gptkbp:introducedIn |
gptkb:Airflow_1.0
1.0.0 |
| gptkbp:isFrequentlyUsed |
True
|
| gptkbp:isIdempotent |
depends on python_callable
|
| gptkbp:maintainedBy |
gptkb:Apache_Software_Foundation
|
| gptkbp:openSource |
True
|
| gptkbp:parameter |
dag
op_args op_kwargs provide_context python_callable task_id templates_dict templates_exts |
| gptkbp:partOf |
gptkb:Apache_Airflow
|
| gptkbp:purpose |
Task execution
|
| gptkbp:selectsTasksFrom |
Task queue
|
| gptkbp:subclassOf |
gptkb:BashOperator
gptkb:BigQueryOperator gptkb:BranchPythonOperator gptkb:DockerOperator gptkb:DummyOperator gptkb:EmailOperator gptkb:KubernetesPodOperator gptkb:MySqlOperator gptkb:PostgresOperator gptkb:SlackAPIPostOperator Airflow Operator S3ToRedshiftOperator SimpleHttpOperator |
| gptkbp:superclass |
gptkb:BaseOperator
|
| gptkbp:supportsTemplating |
True
|
| gptkbp:usedFor |
Workflow Management
executing Python callables in Airflow DAGs Task Automation defining tasks in workflows |
| gptkbp:usedIn |
gptkb:Directed_Acyclic_Graph_(DAG)
gptkb:DAGs Workflow orchestration |
| gptkbp:writtenBy |
gptkb:Python
|
| gptkbp:bfsParent |
gptkb:Apache_Airflow
|
| gptkbp:bfsLayer |
6
|