Skip to content

Commit 0eae681

Browse files
committed
Remove debugging statements
1 parent 7f0de31 commit 0eae681

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

biothings/utils/manager.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -560,7 +560,6 @@ async def _internal_process_runner(callback: partial, job_id: str, pinfo: dict):
560560
logger.debug("Pushing job[%s] to process queue [%s]", job_id, callback.func.__name__)
561561

562562
process_result = self.process_queue.submit(job_pool_operation, **process_job_info)
563-
# process_result = job_pool_operation(**process_job_info)
564563

565564
# process could generate other parallelized jobs and return a Future/Task
566565
if isinstance(process_result, asyncio.Task):
@@ -577,9 +576,7 @@ async def _internal_process_runner(callback: partial, job_id: str, pinfo: dict):
577576
self._process_job_ids.discard(job_id)
578577
logger.debug("Removing job[%s] from tracking: %s", job_id, removed_job)
579578

580-
breakpoint()
581-
process_task = await _internal_process_runner(func, job_id, pinfo)
582-
# process_task = asyncio.create_task(_internal_process_runner(func, job_id, pinfo))
579+
process_task = asyncio.create_task(_internal_process_runner(func, job_id, pinfo))
583580
return process_task
584581

585582
async def defer_to_thread(self, pinfo=None, func: Callable = None, *args) -> asyncio.Task:

0 commit comments

Comments
 (0)