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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
