mc_submit_meta_urls

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

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)

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