[AIRFLOW-6313] Unify example or doc dag owner (#6864)

We already change Airflow DAG default owner to 'airflow' in https://github.com/apache/airflow/pull/4151 but some of our example DAGs and docs are still using owner = 'Airflow', This patch to unify them
2019-12-20 21:09:59 +08:00 · 2019-12-20 21:09:59 +08:00 · 65ef8f3f81
--- a/airflow/contrib/example_dags/example_azure_container_instances_operator.py
+++ b/airflow/contrib/example_dags/example_azure_container_instances_operator.py
@ -25,7 +25,7 @@ from airflow import DAG
 from airflow.contrib.operators.azure_container_instances_operator import AzureContainerInstancesOperator

 default_args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2018, 11, 1),
    'email': ['airflow@example.com'],
--- a/airflow/contrib/example_dags/example_azure_cosmosdb_sensor.py
+++ b/airflow/contrib/example_dags/example_azure_cosmosdb_sensor.py
@ -33,7 +33,7 @@ from airflow.contrib.sensors.azure_cosmos_sensor import AzureCosmosDocumentSenso
 from airflow.utils import dates

 default_args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': dates.days_ago(2),
    'email': ['airflow@example.com'],
--- a/airflow/contrib/example_dags/example_databricks_operator.py
+++ b/airflow/contrib/example_dags/example_databricks_operator.py
@ -37,7 +37,7 @@ from airflow import DAG
 from airflow.contrib.operators.databricks_operator import DatabricksSubmitRunOperator

 default_args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'email': ['airflow@example.com'],
    'depends_on_past': False,
    'start_date': airflow.utils.dates.days_ago(2)
--- a/airflow/contrib/example_dags/example_dingding_operator.py
+++ b/airflow/contrib/example_dags/example_dingding_operator.py
@ -26,7 +26,7 @@ from airflow import DAG
 from airflow.contrib.operators.dingding_operator import DingdingOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'retries': 3,
    'start_date': airflow.utils.dates.days_ago(2)
 }
--- a/airflow/contrib/example_dags/example_emr_job_flow_automatic_steps.py
+++ b/airflow/contrib/example_dags/example_emr_job_flow_automatic_steps.py
@ -27,7 +27,7 @@ from airflow.contrib.operators.emr_create_job_flow_operator import EmrCreateJobF
 from airflow.contrib.sensors.emr_job_flow_sensor import EmrJobFlowSensor

 DEFAULT_ARGS = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': airflow.utils.dates.days_ago(2),
    'email': ['airflow@example.com'],
--- a/airflow/contrib/example_dags/example_emr_job_flow_manual_steps.py
+++ b/airflow/contrib/example_dags/example_emr_job_flow_manual_steps.py
@ -32,7 +32,7 @@ from airflow.contrib.operators.emr_terminate_job_flow_operator import EmrTermina
 from airflow.contrib.sensors.emr_step_sensor import EmrStepSensor

 DEFAULT_ARGS = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': airflow.utils.dates.days_ago(2),
    'email': ['airflow@example.com'],
--- a/airflow/contrib/example_dags/example_kubernetes_executor.py
+++ b/airflow/contrib/example_dags/example_kubernetes_executor.py
@ -26,7 +26,7 @@ from airflow.models import DAG
 from airflow.operators.python_operator import PythonOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2)
 }

--- a/airflow/contrib/example_dags/example_kubernetes_executor_config.py
+++ b/airflow/contrib/example_dags/example_kubernetes_executor_config.py
@ -27,7 +27,7 @@ from airflow.models import DAG
 from airflow.operators.python_operator import PythonOperator

 default_args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2)
 }

--- a/airflow/contrib/example_dags/example_kubernetes_operator.py
+++ b/airflow/contrib/example_dags/example_kubernetes_operator.py
@ -31,7 +31,7 @@ try:
    from airflow.contrib.operators.kubernetes_pod_operator import KubernetesPodOperator

    default_args = {
-        'owner': 'Airflow',
+        'owner': 'airflow',
        'start_date': days_ago(2)
    }

--- a/airflow/contrib/example_dags/example_papermill_operator.py
+++ b/airflow/contrib/example_dags/example_papermill_operator.py
@ -29,7 +29,7 @@ from airflow.models import DAG
 from airflow.operators.papermill_operator import PapermillOperator

 default_args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2)
 }

--- a/airflow/contrib/example_dags/example_qubole_operator.py
+++ b/airflow/contrib/example_dags/example_qubole_operator.py
@ -38,7 +38,7 @@ from airflow.operators.dummy_operator import DummyOperator
 from airflow.operators.python_operator import BranchPythonOperator, PythonOperator

 default_args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': airflow.utils.dates.days_ago(2),
    'email': ['airflow@example.com'],
--- a/airflow/contrib/example_dags/example_qubole_sensor.py
+++ b/airflow/contrib/example_dags/example_qubole_sensor.py
@ -33,7 +33,7 @@ from airflow.contrib.sensors.qubole_sensor import QuboleFileSensor, QubolePartit
 from airflow.utils import dates

 default_args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': dates.days_ago(2),
    'email': ['airflow@example.com'],
--- a/airflow/contrib/example_dags/example_winrm_operator.py
+++ b/airflow/contrib/example_dags/example_winrm_operator.py
@ -38,7 +38,7 @@ from airflow.models import DAG
 from airflow.operators.dummy_operator import DummyOperator

 default_args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2)
 }

--- a/airflow/example_dags/docker_copy_data.py
+++ b/airflow/example_dags/docker_copy_data.py
@ -35,7 +35,7 @@ TODO: Review the workflow, change it accordingly to
 # from airflow.operators.docker_operator import DockerOperator
 #
 # default_args = {
-#     'owner': 'Airflow',
+#     'owner': 'airflow',
 #     'depends_on_past': False,
 #     'start_date': airflow.utils.dates.days_ago(2),
 #     'email': ['airflow@example.com'],
--- a/airflow/example_dags/example_bash_operator.py
+++ b/airflow/example_dags/example_bash_operator.py
@ -27,7 +27,7 @@ from airflow.operators.bash_operator import BashOperator
 from airflow.operators.dummy_operator import DummyOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2),
 }

--- a/airflow/example_dags/example_branch_operator.py
+++ b/airflow/example_dags/example_branch_operator.py
@ -27,7 +27,7 @@ from airflow.operators.dummy_operator import DummyOperator
 from airflow.operators.python_operator import BranchPythonOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2),
 }

--- a/airflow/example_dags/example_branch_python_dop_operator_3.py
+++ b/airflow/example_dags/example_branch_python_dop_operator_3.py
@ -28,7 +28,7 @@ from airflow.operators.dummy_operator import DummyOperator
 from airflow.operators.python_operator import BranchPythonOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2),
    'depends_on_past': True,
 }
--- a/airflow/example_dags/example_docker_operator.py
+++ b/airflow/example_dags/example_docker_operator.py
@ -24,7 +24,7 @@ from datetime import timedelta
 from airflow.operators.docker_operator import DockerOperator

 default_args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': airflow.utils.dates.days_ago(2),
    'email': ['airflow@example.com'],
--- a/airflow/example_dags/example_gcs_to_bq.py
+++ b/airflow/example_dags/example_gcs_to_bq.py
@ -25,7 +25,7 @@ from airflow.operators import bash_operator
 from airflow.operators.gcs_to_bq import GoogleCloudStorageToBigQueryOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2)
 }

--- a/airflow/example_dags/example_http_operator.py
+++ b/airflow/example_dags/example_http_operator.py
@ -28,7 +28,7 @@ from airflow.operators.http_operator import SimpleHttpOperator
 from airflow.sensors.http_sensor import HttpSensor

 default_args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': airflow.utils.dates.days_ago(2),
    'email': ['airflow@example.com'],
--- a/airflow/example_dags/example_pig_operator.py
+++ b/airflow/example_dags/example_pig_operator.py
@ -24,7 +24,7 @@ from airflow.models import DAG
 from airflow.operators.pig_operator import PigOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2),
 }

--- a/airflow/example_dags/example_python_operator.py
+++ b/airflow/example_dags/example_python_operator.py
@ -27,7 +27,7 @@ from airflow.models import DAG
 from airflow.operators.python_operator import PythonOperator, PythonVirtualenvOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2),
 }

--- a/airflow/example_dags/example_short_circuit_operator.py
+++ b/airflow/example_dags/example_short_circuit_operator.py
@ -25,7 +25,7 @@ from airflow.operators.dummy_operator import DummyOperator
 from airflow.operators.python_operator import ShortCircuitOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2),
 }

--- a/airflow/example_dags/example_skip_dag.py
+++ b/airflow/example_dags/example_skip_dag.py
@ -25,7 +25,7 @@ from airflow.models import DAG
 from airflow.operators.dummy_operator import DummyOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2),
 }

--- a/airflow/example_dags/example_subdag_operator.py
+++ b/airflow/example_dags/example_subdag_operator.py
@ -28,7 +28,7 @@ from airflow.operators.subdag_operator import SubDagOperator
 DAG_NAME = 'example_subdag_operator'

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2),
 }

--- a/airflow/example_dags/example_trigger_target_dag.py
+++ b/airflow/example_dags/example_trigger_target_dag.py
@ -30,7 +30,7 @@ from airflow.operators.python_operator import PythonOperator

 dag = DAG(
    dag_id="example_trigger_target_dag",
-    default_args={"start_date": airflow.utils.dates.days_ago(2), "owner": "Airflow"},
+    default_args={"start_date": airflow.utils.dates.days_ago(2), "owner": "airflow"},
    schedule_interval=None,
 )

--- a/airflow/example_dags/example_xcom.py
+++ b/airflow/example_dags/example_xcom.py
@ -24,7 +24,7 @@ from airflow import DAG
 from airflow.operators.python_operator import PythonOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(2),
 }

--- a/airflow/example_dags/tutorial.py
+++ b/airflow/example_dags/tutorial.py
@ -31,7 +31,7 @@ from airflow.operators.bash_operator import BashOperator
 # These args will get passed on to each operator
 # You can override them on a per-task basis during operator initialization
 default_args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': airflow.utils.dates.days_ago(2),
    'email': ['airflow@example.com'],
--- a/airflow/gcp/operators/dataflow.py
+++ b/airflow/gcp/operators/dataflow.py
@ -55,7 +55,7 @@ class DataflowCreateJavaJobOperator(BaseOperator):
    **Example**: ::

        default_args = {
-            'owner': 'Airflow',
+            'owner': 'airflow',
            'depends_on_past': False,
            'start_date':
                (2016, 8, 1),
--- a/docs/concepts.rst
+++ b/docs/concepts.rst
@ -92,7 +92,7 @@ any of its operators. This makes it easy to apply a common parameter to many ope

    default_args = {
        'start_date': datetime(2016, 1, 1),
-        'owner': 'Airflow'
+        'owner': 'airflow'
    }

    dag = DAG('my_dag', default_args=default_args)
--- a/docs/dag-run.rst
+++ b/docs/dag-run.rst
@ -94,7 +94,7 @@ in the configuration file. When turned off, the scheduler creates a DAG run only


    default_args = {
-        'owner': 'Airflow',
+        'owner': 'airflow',
        'depends_on_past': False,
        'email': ['airflow@example.com'],
        'email_on_failure': False,
--- a/docs/lineage.rst
+++ b/docs/lineage.rst
@ -40,7 +40,7 @@ works.
    FILE_CATEGORIES = ["CAT1", "CAT2", "CAT3"]

    args = {
-        'owner': 'Airflow',
+        'owner': 'airflow',
        'start_date': airflow.utils.dates.days_ago(2)
    }

--- a/docs/timezone.rst
+++ b/docs/timezone.rst
@ -77,7 +77,7 @@ words if you have a default time zone setting of ``Europe/Amsterdam`` and create

    default_args=dict(
        start_date=datetime(2016, 1, 1),
-        owner='Airflow'
+        owner='airflow'
    )

    dag = DAG('my_dag', default_args=default_args)
@ -122,7 +122,7 @@ using ``pendulum``.

    default_args=dict(
        start_date=datetime(2016, 1, 1, tzinfo=local_tz),
-        owner='Airflow'
+        owner='airflow'
    )

    dag = DAG('my_tz_dag', default_args=default_args)
--- a/docs/tutorial.rst
+++ b/docs/tutorial.rst
@ -42,7 +42,7 @@ complicated, a line by line explanation follows below.


    default_args = {
-        'owner': 'Airflow',
+        'owner': 'airflow',
        'depends_on_past': False,
        'start_date': datetime(2015, 6, 1),
        'email': ['airflow@example.com'],
@ -133,7 +133,7 @@ of default parameters that we can use when creating tasks.
    from datetime import datetime, timedelta

    default_args = {
-        'owner': 'Airflow',
+        'owner': 'airflow',
        'depends_on_past': False,
        'start_date': datetime(2015, 6, 1),
        'email': ['airflow@example.com'],
@ -318,7 +318,7 @@ something like this:


    default_args = {
-        'owner': 'Airflow',
+        'owner': 'airflow',
        'depends_on_past': False,
        'start_date': datetime(2015, 6, 1),
        'email': ['airflow@example.com'],
--- a/scripts/perf/dags/perf_dag_1.py
+++ b/scripts/perf/dags/perf_dag_1.py
@ -26,7 +26,7 @@ from airflow.models import DAG
 from airflow.operators.bash_operator import BashOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(3),
 }

--- a/scripts/perf/dags/perf_dag_2.py
+++ b/scripts/perf/dags/perf_dag_2.py
@ -26,7 +26,7 @@ from airflow.models import DAG
 from airflow.operators.bash_operator import BashOperator

 args = {
-    'owner': 'Airflow',
+    'owner': 'airflow',
    'start_date': airflow.utils.dates.days_ago(3),
 }