diff --git a/analytics/dagster/src/hello.py b/analytics/dagster/src/hello.py deleted file mode 100644 index e4315af65..000000000 --- a/analytics/dagster/src/hello.py +++ /dev/null @@ -1,17 +0,0 @@ -from dagster import job, op -from dagster import execute_job, DagsterInstance, reconstructable - -# Définition d'un "op" qui représente une étape de traitement -@op -def hello_world(context): - context.log.info('Hello, World!') - -# Définition d'un job utilisant l'op -@job -def hello_world_job(): - hello_world() - -# Exécution du job localement -if __name__ == "__main__": - instance = DagsterInstance.ephemeral() # Utilisation de l'instance éphémère - result = execute_job(reconstructable(hello_world_job), instance=instance) diff --git a/analytics/dagster/src/jobs/housings_ban_addresses_job.py b/analytics/dagster/src/jobs/housings_ban_addresses_job.py index 131aeb9a4..027b4a0d1 100644 --- 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 index a412613e1..f23aca8bf 100644 --- 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():