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) ) ) 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 } )