From b886dfbf555e124a7300fb32f6038c38c1daccb9 Mon Sep 17 00:00:00 2001 From: Max Chis Date: Fri, 3 Oct 2025 15:35:10 -0400 Subject: [PATCH 1/2] Fix bug with wrong task status assigned. --- src/core/tasks/scheduled/impl/mark_never_completed/query.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/core/tasks/scheduled/impl/mark_never_completed/query.py b/src/core/tasks/scheduled/impl/mark_never_completed/query.py index d2ea2576..1aba3aea 100644 --- a/src/core/tasks/scheduled/impl/mark_never_completed/query.py +++ b/src/core/tasks/scheduled/impl/mark_never_completed/query.py @@ -7,6 +7,7 @@ from src.core.enums import BatchStatus from src.db.enums import TaskType from src.db.models.impl.task.core import Task +from src.db.models.impl.task.enums import TaskStatus from src.db.queries.base.builder import QueryBuilderBase @@ -17,10 +18,10 @@ async def run(self, session: AsyncSession) -> Any: update( Task ).values( - task_status=BatchStatus.ABORTED.value + task_status=TaskStatus.NEVER_COMPLETED.value ). where( - Task.task_status == BatchStatus.IN_PROCESS, + Task.task_status == TaskStatus.IN_PROCESS, Task.updated_at < datetime.now() - timedelta(hours=1) ) ) From 9ffa9a9d66e19470d5b106b5788bf568e7cf38c2 Mon Sep 17 00:00:00 2001 From: Max Chis Date: Fri, 3 Oct 2025 15:35:25 -0400 Subject: [PATCH 2/2] Fix bugs --- src/core/tasks/url/operators/submit_meta_urls/core.py | 4 ++-- src/external/pdap/impl/meta_urls/core.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/core/tasks/url/operators/submit_meta_urls/core.py b/src/core/tasks/url/operators/submit_meta_urls/core.py index 2a2e54b6..3202a4cf 100644 --- a/src/core/tasks/url/operators/submit_meta_urls/core.py +++ b/src/core/tasks/url/operators/submit_meta_urls/core.py @@ -75,5 +75,5 @@ async def inner_task_logic(self) -> None: ) ) - await self.adb_client.bulk_insert(errors) - await self.adb_client.bulk_insert(inserts) + await self.adb_client.bulk_insert(errors) + await self.adb_client.bulk_insert(inserts) diff --git a/src/external/pdap/impl/meta_urls/core.py b/src/external/pdap/impl/meta_urls/core.py index f3078924..4a34fbeb 100644 --- a/src/external/pdap/impl/meta_urls/core.py +++ b/src/external/pdap/impl/meta_urls/core.py @@ -37,7 +37,7 @@ async def submit_meta_urls( url=url, headers=headers, json_={ - "data_sources": meta_urls_json + "meta_urls": meta_urls_json } )