(task_data, sort_id)
| 345 | ) |
| 346 | |
| 347 | def createTask(task_data, sort_id): |
| 348 | task_name = get_task_name(task_data) if get_task_name else None |
| 349 | return Task( |
| 350 | status=TaskStatus.PENDING, |
| 351 | scraper_name=scraper_name, |
| 352 | task_name=task_name, |
| 353 | scraper_type=scraper_type, |
| 354 | is_all_task=False, |
| 355 | is_sync=is_sync, |
| 356 | parent_task_id=all_task_id, |
| 357 | data=task_data, |
| 358 | meta_data=metadata, |
| 359 | sort_id=sort_id, # Set the sort_id for the child task |
| 360 | ) |
| 361 | |
| 362 | def create_cached_tasks(task_datas): |
| 363 | ls = [] |
no test coverage detected