update to using a constant

Author: marshallweekley-eng

apps/bfd-pipeline-idr/src/idr_pipeline/constants.py

@@ -255,3 +255,5 @@
 # Need to declare this separately because python struggles
 # with type-hinting empty arrays :(
 EMPTY_PARTITION: list[LoadPartitionGroup] = []
+
+DEFAULT_JOB_ID = 1

apps/bfd-pipeline-idr/src/idr_pipeline/model/load_progress.py

@@ -3,6 +3,7 @@
 
 from ..load_partition import LoadPartition
 from ..model.base_model import IdrBaseModel, ModelType, Source
+from ..constants import DEFAULT_JOB_ID
 
 
 class LoadProgress(IdrBaseModel):
@@ -37,14 +38,7 @@ def model_type() -> ModelType:
     @override
     @classmethod
     def fetch_query(cls, partition: LoadPartition, start_time: datetime, source: Source) -> str:
-        return f"""
-        SELECT table_name, last_ts, last_id, batch_partition, job_start_ts,
-          batch_complete_ts, job_id, max_run_ts
-        FROM idr.load_progress
-        WHERE table_name = %({LoadProgress.query_placeholder()})s 
-        AND batch_partition = '{partition.name}'
-        AND job_id = 1
-        """
+        return cls.fetch_query_by_job(partition, DEFAULT_JOB_ID) 
 
     @classmethod
     def fetch_query_by_job(cls, partition: LoadPartition, job_id: int) -> str: