add region tags for aws + azure tutorials (#8218)

teeny PR to add some region tags

Author: leahecole

composer/workflows/azureblobstoretogcsoperator_tutorial.py

@@ -12,6 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+# [START composer_dataanalyticstutorial_azure_dag]
 import datetime
 
 from airflow import models
@@ -53,13 +54,12 @@
             f"{BQ_DESTINATION_DATASET_NAME}.{BQ_DESTINATION_TABLE_NAME}",
             f"{BQ_DESTINATION_DATASET_NAME}.{BQ_NORMALIZED_TABLE_NAME}",
         ],
-
     },
     "environment_config": {
         "execution_config": {
             "service_account": "{{var.value.dataproc_service_account}}"
         }
-    }
+    },
 }
 
 yesterday = datetime.datetime.combine(
@@ -73,7 +73,7 @@
     # To email on failure or retry set 'email' arg to your email and enable
     # emailing here.
     "email_on_failure": False,
-    "email_on_retry": False
+    "email_on_retry": False,
 }
 
 with models.DAG(
@@ -161,3 +161,4 @@
             )
 
         azure_blob_to_gcs >> load_external_dataset >> bq_join_group >> create_batch
+# [END composer_dataanalyticstutorial_azure_dag]

composer/workflows/s3togcsoperator_tutorial.py

@@ -12,6 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+# [START composer_dataanalyticstutorial_aws_dag]
 import datetime
 
 from airflow import models
@@ -49,13 +50,12 @@
             f"{BQ_DESTINATION_DATASET_NAME}.{BQ_DESTINATION_TABLE_NAME}",
             f"{BQ_DESTINATION_DATASET_NAME}.{BQ_NORMALIZED_TABLE_NAME}",
         ],
-
     },
     "environment_config": {
         "execution_config": {
             "service_account": "{{var.value.dataproc_service_account}}"
         }
-    }
+    },
 }
 
 yesterday = datetime.datetime.combine(
@@ -69,7 +69,7 @@
     # To email on failure or retry set 'email' arg to your email and enable
     # emailing here.
     "email_on_failure": False,
-    "email_on_retry": False
+    "email_on_retry": False,
 }
 
 with models.DAG(
@@ -106,7 +106,7 @@
             {"name": "Holiday", "type": "STRING"},
         ],
         skip_leading_rows=1,
-        write_disposition="WRITE_TRUNCATE"
+        write_disposition="WRITE_TRUNCATE",
     )
 
     with TaskGroup("join_bq_datasets") as bq_join_group:
@@ -148,3 +148,4 @@
             )
 
         s3_to_gcs_op >> load_external_dataset >> bq_join_group >> create_batch
+# [END composer_dataanalyticstutorial_aws_dag]