DAGs: db connection name change

cern-sis · Jul 31, 2024 · 1ba37db · 1ba37db
1 parent 963537b
commit 1ba37db
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/README.md b/README.md
@@ -81,7 +81,7 @@ Lastly, add the necessary Airflow connections through the UI.
 
 - Navigate to Admin -> Connections in the Airflow UI.
 - Click on "Add" and fill in the details:
-  - Connection Id: `superset_qa`
+  - Connection Id: `superset`
   - Login: `airflow`
   - Database: `airflow`
   - Password: `airflow`

diff --git a/dags/library/cern_publication_records.py b/dags/library/cern_publication_records.py
@@ -61,7 +61,7 @@ def join_and_add_year(counts, **kwargs):
 
     results = join_and_add_year(counts)
 
-    @sqlalchemy_task(conn_id="superset_qa")
+    @sqlalchemy_task(conn_id="superset")
     def populate_cern_publication_records(results, session, **kwargs):
         record = (
             session.query(LibraryCernPublicationRecords)

diff --git a/dags/library/new_items_in_the_institutional_repository.py b/dags/library/new_items_in_the_institutional_repository.py
@@ -60,7 +60,7 @@ def join_and_add_year(counts, **kwargs):
 
     results = join_and_add_year(counts)
 
-    @sqlalchemy_task(conn_id="superset_qa")
+    @sqlalchemy_task(conn_id="superset")
     def populate_new_items_in_the_institutional_repository(results, session, **kwargs):
         record = (
             session.query(LibraryNewItemsInTheInstitutionalRepository)

diff --git a/dags/open_access/gold_open_access_mechanisms.py b/dags/open_access/gold_open_access_mechanisms.py
@@ -71,7 +71,7 @@ def join_and_add_year(counts, **kwargs):
 
     results = join_and_add_year(counts)
 
-    @sqlalchemy_task(conn_id="superset_qa")
+    @sqlalchemy_task(conn_id="superset")
     def populate_golden_open_access(results, session, **kwargs):
         record = (
             session.query(OAGoldenOpenAccess).filter_by(year=results["year"]).first()

diff --git a/dags/open_access/open_access.py b/dags/open_access/open_access.py
@@ -78,7 +78,7 @@ def join_and_add_year(counts, **kwargs):
 
     results = join_and_add_year(counts)
 
-    @sqlalchemy_task(conn_id="superset_qa")
+    @sqlalchemy_task(conn_id="superset")
     def populate_open_access(results, session, **kwargs):
         record = session.query(OAOpenAccess).filter_by(year=results["year"]).first()
         if record: