diff --git a/warehouse/oso_dagster/goldsky.py b/warehouse/oso_dagster/goldsky.py index bd098f7b0..915069f4e 100644 --- a/warehouse/oso_dagster/goldsky.py +++ b/warehouse/oso_dagster/goldsky.py @@ -317,9 +317,13 @@ def commit_pointer( job_config=job_config, timeout=self.config.load_table_timeout_seconds, ) - self.update_pointer_table(client, context, checkpoint, pointer_table_mutex) - context.log.debug("updated pointer table") load_job.result() + context.log.info(f"Worker[{self.name}] Data loaded into bigquery") + + self.update_pointer_table(client, context, checkpoint, pointer_table_mutex) + context.log.info( + f"Worker[{self.name}] Pointer table updated to {checkpoint.worker_checkpoint}" + ) def run_load_bigquery_load( self,