only monitor active datasets

WIPACrepo · Feb 7, 2025 · 7df495b · 7df495b
1 parent 9b9c821
commit 7df495b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/iceprod/scheduled_tasks/dataset_monitor.py b/iceprod/scheduled_tasks/dataset_monitor.py
@@ -45,6 +45,9 @@ async def process_dataset(rest_client, dataset_id):
     dataset = await rest_client.request('GET', f'/datasets/{dataset_id}')
     dataset_num = dataset['dataset']
     dataset_status = dataset['status']
+    if dataset_status != 'processing':
+        return
+
     with DatasetMonitorDuration.labels(name='dataset_monitor', dataset=str(dataset_num)).time():
         jobs = await rest_client.request('GET', f'/datasets/{dataset_id}/job_counts/status')
         jobs_counter = Counter()