Use gcp_conn_id where appropriate (#20)

unacast · Jun 28, 2022 · b9c8a64 · b9c8a64
1 parent c0e93a2
commit b9c8a64
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/unaflow/dags/trigger_dag/providers/google/gcs_trigger_dag_configuration.py b/unaflow/dags/trigger_dag/providers/google/gcs_trigger_dag_configuration.py
@@ -42,7 +42,7 @@ def __init__(self,
                  prefix: str = None,
                  destination_bucket=None,
                  destination=None,
-                 gcp_conn_id='google_cloud_default',
+                 gcp_conn_id=None,
                  delegate_to=None,
                  single_file=True,
                  *args, **kwargs
@@ -84,7 +84,7 @@ def create_downstream_sensor(self) -> Union[TaskMixin, Sequence[TaskMixin]]:
             destination_bucket=self.destination_bucket,
             destination_object=self.destination,
             move_object=True,
-            google_cloud_storage_conn_id=self.gcp_conn_id,
+            gcp_conn_id=self.gcp_conn_id,
             delegate_to=self.delegate_to
         )