refactoring: remove hello world + fix psycopg2_connection resource name

MTES-MCT · Jan 28, 2025 · 62b71ab · 62b71ab
1 parent e83fad1
commit 62b71ab
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 21 deletions.
diff --git a/analytics/dagster/src/hello.py b/analytics/dagster/src/hello.py
diff --git a/analytics/dagster/src/jobs/housings_ban_addresses_job.py b/analytics/dagster/src/jobs/housings_ban_addresses_job.py
@@ -1,13 +1,13 @@
 from dagster import job
 from dagster.src.assets.populate_owners_ban_addresses import housings_without_address
 from dagster.src.resources.ban_config import ban_config_resource
-from dagster.src.resources import sqlalchemy_engine_resource, postgres_resource
+from dagster.src.resources import sqlalchemy_engine_resource, psycopg2_connection_resource
 
 @job(
     resource_defs={
         "ban_config": ban_config_resource,
         "sqlalchemy_engine": sqlalchemy_engine_resource,
-        "postgres": postgres_resource,
+        "psycopg2_connection_resource": psycopg2_connection_resource,
     }
 )
 def housings_ban_addresses_job():

diff --git a/analytics/dagster/src/jobs/owners_ban_addresses_job.py b/analytics/dagster/src/jobs/owners_ban_addresses_job.py
@@ -1,13 +1,13 @@
 from dagster import job
 from dagster.src.assets.populate_owners_ban_addresses import owners_without_address
 from dagster.src.resources.ban_config import ban_config_resource
-from dagster.src.resources import sqlalchemy_engine_resource, postgres_resource
+from dagster.src.resources import sqlalchemy_engine_resource, psycopg2_connection_resource
 
 @job(
     resource_defs={
         "ban_config": ban_config_resource,
         "sqlalchemy_engine": sqlalchemy_engine_resource,
-        "postgres": postgres_resource,
+        "psycopg2_connection": psycopg2_connection_resource,
     }
 )
 def owners_ban_addresses_job():