Path	Lines of Code
composer/2022_airflow_summit/__init__.py	1
composer/2022_airflow_summit/bigquery_permissions.py	14
composer/2022_airflow_summit/data_analytics_dag.py	86
composer/2022_airflow_summit/data_analytics_dag_expansion.py	96
composer/2022_airflow_summit/data_analytics_process.py	23
composer/2022_airflow_summit/data_analytics_process_expansion.py	110
composer/2022_airflow_summit/data_processing_helper.py	21
composer/2022_airflow_summit/noxfile_config.py	17
composer/2022_airflow_summit/parallel_work.py	20
composer/2022_airflow_summit/retries.py	31
composer/airflow_1_samples/__init__.py	1
composer/airflow_1_samples/airflow_db_cleanup.py	313
composer/airflow_1_samples/bq_copy_across_locations.py	73
composer/airflow_1_samples/bq_notify.py	105
composer/airflow_1_samples/clear_file_system_caches_dag.py	21
composer/airflow_1_samples/conftest.py	10
composer/airflow_1_samples/connections.py	29
composer/airflow_1_samples/dataflowtemplateoperator_tutorial.py	32
composer/airflow_1_samples/dataproc_workflow_template_instantiate_operator_tutorial.py	20
composer/airflow_1_samples/gke_operator.py	120
composer/airflow_1_samples/grouping.py	15
composer/airflow_1_samples/hadoop_tutorial.py	54
composer/airflow_1_samples/kubernetes_pod_operator.py	100
composer/airflow_1_samples/noxfile_config.py	9
composer/airflow_1_samples/quickstart.py	23
composer/airflow_1_samples/relationship_child.py	7
composer/airflow_1_samples/relationship_parent.py	24
composer/airflow_1_samples/simple.py	22
composer/airflow_1_samples/trigger_response_dag.py	21
composer/airflow_1_samples/unit_testing_cycle.py	15
composer/airflow_1_samples/unit_testing_variables.py	20
composer/airflow_1_samples/use_local_deps.py	16
composer/blog/__init__.py	1
composer/blog/gcp-tech-blog/__init__.py	1
composer/blog/gcp-tech-blog/data-orchestration-with-composer/__init__.py	1
composer/blog/gcp-tech-blog/data-orchestration-with-composer/conftest.py	10
composer/blog/gcp-tech-blog/data-orchestration-with-composer/dags/__init__.py	1
composer/blog/gcp-tech-blog/data-orchestration-with-composer/dags/data_orchestration_blog_sample_dag.py	58
composer/blog/gcp-tech-blog/data-orchestration-with-composer/noxfile_config.py	16
composer/cicd_sample/__init__.py	1
composer/cicd_sample/add-dags-to-composer.cloudbuild.yaml	7
composer/cicd_sample/dags/__init__.py	1
composer/cicd_sample/dags/example2_dag.py	23
composer/cicd_sample/dags/example_dag.py	23
composer/cicd_sample/noxfile_config.py	16
composer/cicd_sample/test-dags.cloudbuild.yaml	10
composer/cicd_sample/utils/add_dags_to_composer.py	48
composer/cicd_sample/utils/noxfile_config.py	17
composer/conftest.py	19
composer/dag_test_utils/internal_unit_testing.py	10
composer/dag_test_utils/pyproject.toml	3
composer/dag_test_utils/setup.py	18
composer/functions/composer_storage_trigger.py	41
composer/functions/pubsub_publisher.py	19
composer/rest/README.rst.in	21
composer/rest/__init__.py	1
composer/rest/composer2/composer2_airflow_rest_api.py	43
composer/rest/get_client_id.py	42
composer/rest/get_dag_prefix.py	26
composer/tools/__init__.py	1
composer/tools/composer_dags.py	192
composer/tools/composer_migrate.py	392
composer/workflows/__init__.py	1
composer/workflows/airflow_db_cleanup.py	390
composer/workflows/airflow_moved_tables.py	46
composer/workflows/azureblobstoretogcsoperator_tutorial.py	105
composer/workflows/bq_copy_across_locations.py	73
composer/workflows/bq_notify.py	118
composer/workflows/clear_file_system_caches_dag_composer_v1.py	21
composer/workflows/cloud-build.yaml	4
composer/workflows/connections.py	28
composer/workflows/create_asynchronous_dataform_workflow_invocation.py	56
composer/workflows/create_dataform_workflow_invocation.py	41
composer/workflows/dataflowtemplateoperator_create_dataset_and_table_helper.py	26
composer/workflows/dataflowtemplateoperator_tutorial.py	34
composer/workflows/dataproc_batch_operators.py	115
composer/workflows/dataproc_workflow_template_instantiate_operator_tutorial.py	22
composer/workflows/email_operator_sendgrid.py	15
composer/workflows/gke_operator.py	117
composer/workflows/grouping.py	15
composer/workflows/hadoop_tutorial.py	61
composer/workflows/kubernetes_pod_operator.py	105
composer/workflows/kubernetes_pod_operator_c2.py	85
composer/workflows/noxfile_config.py	18
composer/workflows/pubsub_trigger_response_dag.py	61
composer/workflows/quickstart.py	23
composer/workflows/relationship_child.py	7
composer/workflows/relationship_parent.py	24
composer/workflows/s3togcsoperator_tutorial.py	97
composer/workflows/simple.py	18
composer/workflows/taskgroup.py	16
composer/workflows/trigger_response_dag.py	11
composer/workflows/unit_testing_cycle.py	14
composer/workflows/unit_testing_variables.py	20
composer/workflows/use_local_deps.py	16