|
549 | 549 | task = nothing |
550 | 550 | @label pop_task |
551 | 551 | if task !== nothing |
| 552 | + @dagdebug task :schedule "Finished scheduling task" |
552 | 553 | @maybelog ctx timespan_finish(ctx, :schedule, (;uid=state.uid, thunk_id=task.id), (;thunk_id=task.id)) |
553 | 554 | end |
554 | 555 | if isempty(state.ready) |
|
564 | 565 | finish_failed!(state, task) |
565 | 566 | else |
566 | 567 | # This shouldn't have happened |
| 568 | + @dagdebug task :schedule "Scheduling inconsistency: Task being scheduled is already cached!" |
567 | 569 | iob = IOBuffer() |
568 | 570 | println(iob, "Scheduling inconsistency: Task being scheduled is already cached!") |
569 | 571 | println(iob, " Task: $(task.id)") |
|
591 | 593 | if scope isa InvalidScope |
592 | 594 | ex = SchedulingException("compute_scope and result_scope are not compatible: $(scope.x), $(scope.y)") |
593 | 595 | store_result!(state, task, ex; error=true) |
594 | | - set_failed!(state, task) |
| 596 | + finish_failed!(state, task) |
595 | 597 | @goto pop_task |
596 | 598 | end |
597 | 599 | for arg in task.inputs |
|
608 | 610 | if scope isa InvalidScope |
609 | 611 | ex = SchedulingException("Current scope and argument Chunk scope are not compatible: $(scope.x), $(scope.y)") |
610 | 612 | store_result!(state, task, ex; error=true) |
611 | | - set_failed!(state, task) |
| 613 | + finish_failed!(state, task) |
612 | 614 | @goto pop_task |
613 | 615 | end |
614 | 616 | end |
|
669 | 671 |
|
670 | 672 | ex = SchedulingException("No processors available, try widening scope") |
671 | 673 | store_result!(state, task, ex; error=true) |
672 | | - set_failed!(state, task) |
| 674 | + finish_failed!(state, task) |
673 | 675 | @dagdebug task :schedule "No processors available, skipping" |
674 | 676 | sorted_procs_cleanup() |
675 | 677 | costs_cleanup() |
|
0 commit comments