josh-fell commented on a change in pull request #19062: URL: https://github.com/apache/airflow/pull/19062#discussion_r731458987
########## File path: airflow/providers/microsoft/azure/example_dags/example_azure_blob_to_gcs.py ########## @@ -16,44 +16,33 @@ # specific language governing permissions and limitations # under the License. import os +from datetime import datetime from airflow import DAG from airflow.providers.microsoft.azure.sensors.wasb import WasbBlobSensor from airflow.providers.microsoft.azure.transfers.azure_blob_to_gcs import AzureBlobStorageToGCSOperator -from airflow.utils.dates import days_ago BLOB_NAME = os.environ.get("AZURE_BLOB_NAME", "file.txt") AZURE_CONTAINER_NAME = os.environ.get("AZURE_CONTAINER_NAME", "airflow") GCP_BUCKET_FILE_PATH = os.environ.get("GCP_BUCKET_FILE_PATH", "file.txt") GCP_BUCKET_NAME = os.environ.get("GCP_BUCKET_NAME", "INVALID BUCKET NAME") GCP_OBJECT_NAME = os.environ.get("GCP_OBJECT_NAME", "file.txt") - +# [START how_to_azure_blob_to_gcs] with DAG( "example_azure_blob_to_gcs", schedule_interval=None, - start_date=days_ago(1), # Override to match your needs + start_date=datetime(2021, 1, 1), # Override to match your needs + default_args={"container_name": AZURE_CONTAINER_NAME, "blob_name": BLOB_NAME}, ) as dag: - # [START how_to_wait_for_blob] Review comment: Removed this tag as it was not being used in any documentation. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org