Skip to content

Commit 8d07d36

Browse files
committed
fix: fix the collection task creation
1 parent 4616358 commit 8d07d36

2 files changed

Lines changed: 1 addition & 1 deletion

File tree

runtime/datamate-python/app/module/collection/client/datax_client.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@ def validate_json_string(self) -> Dict[str, Any]:
3030
"""
3131
try:
3232
config = json.loads(self.task.config)
33-
logger.info(f"config: {config} \n {self.task.config}")
3433

3534
# 基本验证
3635
if 'job' not in config:

runtime/datamate-python/app/module/collection/service/collection.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@ async def create_task(self, task: CollectionTask) -> CollectionTask:
2424
# If it's a one-time task, execute it immediately
2525
if task.sync_mode == SyncMode.ONCE:
2626
task.status = TaskStatus.RUNNING.name
27+
await self.db.commit()
2728
asyncio.create_task(self.run_async(task.id))
2829
return task
2930

0 commit comments

Comments
 (0)