Address lint

Author: ethany-nv

src/utils/job/jobs.py

@@ -205,7 +205,6 @@ def execute(self, context: JobExecutionContext,
         Executes the job. Returns true if the job was completed successful and can
         be removed from the message queue, or false if the job failed.
         """
-        last_timestamp = datetime.datetime.now()
         postgres = context.postgres
 
         # Create workflow and groups in database

src/utils/job/task.py

@@ -1045,7 +1045,7 @@ class Config:
     def batch_insert_to_db(
         database: connectors.PostgresConnector,
         task_entries: List[Tuple],
-        batch_size: int = 100,
+        batch_size: int = 2,
     ):
         """Batch-insert multiple tasks in a single query.
 
@@ -1058,6 +1058,9 @@ def batch_insert_to_db(
         if not task_entries:
             return
 
+        if batch_size <= 0:
+            batch_size = 100
+
         for i in range(0, len(task_entries), batch_size):
             chunk = task_entries[i:i + batch_size]
             values_clause = ','.join(

src/utils/job/workflow.py

@@ -632,7 +632,7 @@ def validate_data(self, user: str, dataset_config: connectors.DatasetConfig,
                       group_task: task.TaskSpec, seen_uri_input: Set[str],
                       seen_uri_output: Set[str], disabled_data: List[str],
                       seen_bucket_input: Set[str], seen_bucket_output: Set[str],
-                      default_user_bucket: Optional[str],
+                      default_user_bucket: str | None,
                       default_service_bucket: str,
                       user_creds: Dict[str, Any]):