execution_aware_scheduler.go ×1
Frontier kind: Joint frontier
unlabeled · c_be550550fbce
1 test · 1859 LOC · 72 files · introduces 1 test · 3 LOC · 1 file
Introduces — evidence that enters the hierarchy at this concept
Code
1 range 3 lines · 1 files
Tests
1 test
Contains — complete concept membership
Neighbourhood graph
The orange circle is the focus. Violet and green circles are every ancestor and descendant, broader and narrower, at any distance; blue squares and pink diamonds are the introduced files and exact introduced tests of every visible concept, not only the focus's. Arrows point from broader to narrower concepts and bridge only concepts omitted from this view. Undirected links show source or test introduction. Concept and file size follows LOC; exact test nodes use test-count units.
Introduced files, introduced tests, and structurally relevant concept specialization
In the embedded map, ordinary wheel input scrolls the page; use the visible controls to zoom and drag to pan. Open the full-screen map for canvas navigation: wheel pans, Ctrl/Command plus wheel zooms, and arrow keys pan when this region is focused. On touch screens, open the full-screen map to pan or pinch. If JavaScript or WebGL is unavailable, use the native relationship evidence on this page.
Introduced files, introduced tests, and structurally relevant concept specialization execution_aware_scheduler.go ×1 · 1 introduced LOC execution_aware_schedule… TestHasQueue, TestTrySubmit_ExistingQueue · 0 introduced LOC TestHasQueue, TestTrySub… TestTrySubmit_Success, TestParallelTrySubmit_SameWorkflow, +3 · 0 introduced LOC TestTrySubmit_Success, T… execution_queue_scheduler.go ×2 · 6 introduced LOC execution_queue_schedule… execution_queue_scheduler.go ×5 · 21 introduced LOC execution_queue_schedule… execution_queue_scheduler.go ×1 · 2 introduced LOC execution_queue_schedule… execution_queue_scheduler.go ×8 · 47 introduced LOC execution_queue_schedule… execution_aware_scheduler.go ×1 · 1 introduced LOC execution_aware_schedule… TestStartStop_Enabled, TestStartStop_Disabled · 0 introduced LOC TestStartStop_Enabled, T… task_mock.go ×1 · 4 introduced LOC task_mock.go ×1 task_mock.go ×2 · 12 introduced LOC task_mock.go ×2 execution_aware_scheduler.go ×1 · 4 introduced LOC execution_aware_schedule… execution_queue_scheduler.go ×1 · 6 introduced LOC execution_queue_schedule… execution_queue_scheduler.go ×3 · 7 introduced LOC execution_queue_schedule… scheduler_mock.go ×2 · 8 introduced LOC scheduler_mock.go ×2 task_mock.go ×1 · 4 introduced LOC task_mock.go ×1 execution_aware_scheduler.go ×1 · 2 introduced LOC execution_aware_schedule… task_mock.go ×2 · 8 introduced LOC task_mock.go ×2 execution_aware_scheduler.go ×1 · 2 introduced LOC execution_aware_schedule… execution_aware_scheduler.go ×1 · 8 introduced LOC execution_aware_schedule… execution_aware_scheduler.go ×1 · 2 introduced LOC execution_aware_schedule… scheduler_mock.go ×3 · 11 introduced LOC scheduler_mock.go ×3 execution_queue_scheduler.go ×2 · 3 introduced LOC execution_queue_schedule… execution_aware_scheduler.go ×1 · 17 introduced LOC execution_aware_schedule… task_mock.go ×1 · 3 introduced LOC task_mock.go ×1 execution_queue_scheduler.go ×1 · 15 introduced LOC execution_queue_schedule… noop_impl.go ×1 · 3 introduced LOC noop_impl.go ×1 noop_impl.go ×1 · 3 introduced LOC noop_impl.go ×1 noop_impl.go ×1 · 1 introduced LOC noop_impl.go ×1 noop_impl.go ×1 · 1 introduced LOC noop_impl.go ×1 noop_logger.go ×1 · 1 introduced LOC noop_logger.go ×1 scheduler_mock.go ×1 · 5 introduced LOC scheduler_mock.go ×1 task_mock.go ×1 · 5 introduced LOC task_mock.go ×1 priority.go ×1 · 3 introduced LOC priority.go ×1 setting_gen.go ×51 · 335 introduced LOC setting_gen.go ×51 noop_impl.go ×1 · 3 introduced LOC noop_impl.go ×1 util.go ×1 · 3 introduced LOC util.go ×1 noop_impl.go ×1 · 1 introduced LOC noop_impl.go ×1 util.go ×2 · 12 introduced LOC util.go ×2 service.pb.go ×2 · 342 introduced LOC service.pb.go ×2 message.pb.go ×2 · 20 introduced LOC message.pb.go ×2 message.pb.go ×2 · 442 introduced LOC message.pb.go ×2 defs.go ×1 · 3 introduced LOC defs.go ×1 defs.go ×1 · 3 introduced LOC defs.go ×1 defs.go ×1 · 3 introduced LOC defs.go ×1 metrics.go ×1 · 1 introduced LOC metrics.go ×1 metrics.go ×1 · 1 introduced LOC metrics.go ×1 metrics.go ×1 · 1 introduced LOC metrics.go ×1 defs.go ×5 · 91 introduced LOC defs.go ×5 noop_logger.go ×1 · 3 introduced LOC noop_logger.go ×1 tags.go ×9 · 37 introduced LOC tags.go ×9 message.pb.go ×2 · 49 introduced LOC message.pb.go ×2 cluster.pb.go ×2 · 200 introduced LOC cluster.pb.go ×2 retry.go ×1 · 2 introduced LOC retry.go ×1 retry.go ×1 · 3 introduced LOC retry.go ×1 retry.go ×1 · 1 introduced LOC retry.go ×1 retry.go ×2 · 11 introduced LOC retry.go ×2 wildcard.go ×1 · 2 introduced LOC wildcard.go ×1 retrypolicy.go ×1 · 8 introduced LOC retrypolicy.go ×1 wildcard.go ×4 · 14 introduced LOC wildcard.go ×4 retrypolicy.go ×3 · 19 introduced LOC retrypolicy.go ×3 message.pb.go ×2 · 20 introduced LOC message.pb.go ×2 time_source.go ×1 · 3 introduced LOC time_source.go ×1 time_source.go ×1 · 4 introduced LOC time_source.go ×1 time_source.go ×1 · 3 introduced LOC time_source.go ×1 TestOperatorServiceMetadata, TestWorkflowServiceMetadata · 0 introduced LOC TestOperatorServiceMetad… go.temporal.io/server/api/adminservice/v1/request_response.pb.go · 6661 LOC v1/request_response.pb.g… go.temporal.io/server/api/adminservice/v1/service.pb.go · 297 LOC v1/service.pb.go go.temporal.io/server/api/clock/v1/message.pb.go · 217 LOC v1/message.pb.go go.temporal.io/server/api/cluster/v1/message.pb.go · 366 LOC v1/message.pb.go go.temporal.io/server/api/common/v1/api_category.pb.go · 230 LOC v1/api_category.pb.go go.temporal.io/server/api/common/v1/dlq.pb.go · 319 LOC v1/dlq.pb.go go.temporal.io/server/api/deployment/v1/message.pb.go · 4650 LOC v1/message.pb.go go.temporal.io/server/api/enums/v1/cluster.pb.go · 233 LOC v1/cluster.pb.go go.temporal.io/server/api/enums/v1/common.pb.go · 288 LOC v1/common.pb.go go.temporal.io/server/api/enums/v1/dlq.pb.go · 211 LOC v1/dlq.pb.go go.temporal.io/server/api/enums/v1/fairness_state.pb.go · 147 LOC v1/fairness_state.pb.go go.temporal.io/server/api/enums/v1/nexus.pb.go · 182 LOC v1/nexus.pb.go go.temporal.io/server/api/enums/v1/predicate.pb.go · 194 LOC v1/predicate.pb.go go.temporal.io/server/api/enums/v1/replication.pb.go · 338 LOC v1/replication.pb.go go.temporal.io/server/api/enums/v1/task.pb.go · 480 LOC v1/task.pb.go go.temporal.io/server/api/enums/v1/workflow.pb.go · 299 LOC v1/workflow.pb.go go.temporal.io/server/api/enums/v1/workflow_task_type.pb.go · 148 LOC v1/workflow_task_type.pb… go.temporal.io/server/api/errordetails/v1/message.pb.go · 649 LOC v1/message.pb.go go.temporal.io/server/api/health/v1/message.pb.go · 324 LOC v1/message.pb.go go.temporal.io/server/api/history/v1/message.pb.go · 522 LOC v1/message.pb.go go.temporal.io/server/api/historyservice/v1/request_response.pb.go · 12003 LOC v1/request_response.pb.g… go.temporal.io/server/api/historyservice/v1/service.pb.go · 452 LOC v1/service.pb.go go.temporal.io/server/api/matchingservice/v1/request_response.pb.go · 6878 LOC v1/request_response.pb.g… go.temporal.io/server/api/matchingservice/v1/service.pb.go · 274 LOC v1/service.pb.go go.temporal.io/server/api/metrics/v1/message.pb.go · 128 LOC v1/message.pb.go go.temporal.io/server/api/namespace/v1/message.pb.go · 138 LOC v1/message.pb.go go.temporal.io/server/api/persistence/v1/chasm.pb.go · 1215 LOC v1/chasm.pb.go go.temporal.io/server/api/persistence/v1/chasm_visibility.pb.go · 170 LOC v1/chasm_visibility.pb.g… go.temporal.io/server/api/persistence/v1/cluster_metadata.pb.go · 313 LOC v1/cluster_metadata.pb.g… go.temporal.io/server/api/persistence/v1/executions.pb.go · 5768 LOC v1/executions.pb.go go.temporal.io/server/api/persistence/v1/history_tree.pb.go · 298 LOC v1/history_tree.pb.go go.temporal.io/server/api/persistence/v1/hsm.pb.go · 929 LOC v1/hsm.pb.go go.temporal.io/server/api/persistence/v1/namespaces.pb.go · 560 LOC v1/namespaces.pb.go go.temporal.io/server/api/persistence/v1/nexus.pb.go · 509 LOC v1/nexus.pb.go go.temporal.io/server/api/persistence/v1/predicates.pb.go · 864 LOC v1/predicates.pb.go go.temporal.io/server/api/persistence/v1/queue_metadata.pb.go · 129 LOC v1/queue_metadata.pb.go go.temporal.io/server/api/persistence/v1/queues.pb.go · 641 LOC v1/queues.pb.go go.temporal.io/server/api/persistence/v1/task_queues.pb.go · 924 LOC v1/task_queues.pb.go go.temporal.io/server/api/persistence/v1/tasks.pb.go · 870 LOC v1/tasks.pb.go go.temporal.io/server/api/persistence/v1/update.pb.go · 455 LOC v1/update.pb.go go.temporal.io/server/api/persistence/v1/workflow_mutable_state.pb.go · 560 LOC v1/workflow_mutable_stat… go.temporal.io/server/api/replication/v1/message.pb.go · 2481 LOC v1/message.pb.go go.temporal.io/server/api/taskqueue/v1/message.pb.go · 1363 LOC v1/message.pb.go go.temporal.io/server/api/token/v1/message.pb.go · 809 LOC v1/message.pb.go go.temporal.io/server/api/workflow/v1/message.pb.go · 302 LOC v1/message.pb.go go.temporal.io/server/common/backoff/retry.go · 207 LOC backoff/retry.go go.temporal.io/server/common/backoff/retrypolicy.go · 347 LOC backoff/retrypolicy.go go.temporal.io/server/common/build/build.go · 56 LOC build/build.go go.temporal.io/server/common/clock/time_source.go · 56 LOC clock/time_source.go go.temporal.io/server/common/dynamicconfig/collection.go · 779 LOC dynamicconfig/collection… go.temporal.io/server/common/dynamicconfig/deepcopy.go · 78 LOC dynamicconfig/deepcopy.g… go.temporal.io/server/common/dynamicconfig/gradual_change.go · 196 LOC dynamicconfig/gradual_ch… go.temporal.io/server/common/dynamicconfig/key.go · 21 LOC dynamicconfig/key.go go.temporal.io/server/common/dynamicconfig/registry.go · 44 LOC dynamicconfig/registry.g… go.temporal.io/server/common/dynamicconfig/setting_gen.go · 1972 LOC dynamicconfig/setting_ge… go.temporal.io/server/common/dynamicconfig/shared_structure.go · 69 LOC dynamicconfig/shared_str… go.temporal.io/server/common/log/noop_logger.go · 25 LOC log/noop_logger.go go.temporal.io/server/common/log/tag/tags.go · 1039 LOC tag/tags.go go.temporal.io/server/common/log/tag/zap_tag.go · 242 LOC tag/zap_tag.go go.temporal.io/server/common/metrics/defs.go · 76 LOC metrics/defs.go go.temporal.io/server/common/metrics/defs_base.go · 30 LOC metrics/defs_base.go go.temporal.io/server/common/metrics/metrics.go · 85 LOC metrics/metrics.go go.temporal.io/server/common/metrics/noop_impl.go · 58 LOC metrics/noop_impl.go go.temporal.io/server/common/metrics/option.go · 21 LOC metrics/option.go go.temporal.io/server/common/metrics/registry.go · 75 LOC metrics/registry.go go.temporal.io/server/common/tasks/execution_aware_scheduler.go · 129 LOC tasks/execution_aware_sc… go.temporal.io/server/common/tasks/execution_queue_scheduler.go · 285 LOC tasks/execution_queue_sc… go.temporal.io/server/common/tasks/priority.go · 81 LOC tasks/priority.go go.temporal.io/server/common/tasks/scheduler_mock.go · 90 LOC tasks/scheduler_mock.go go.temporal.io/server/common/tasks/task_mock.go · 220 LOC tasks/task_mock.go go.temporal.io/server/common/util.go · 791 LOC common/util.go go.temporal.io/server/common/util/wildcard.go · 50 LOC util/wildcard.go TestOperatorServiceMetadata · introduced test · go.temporal.io/server/common/api/TestOperatorServiceMetadata TestOperatorServiceMetad… TestWorkflowServiceMetadata · introduced test · go.temporal.io/server/common/api/TestWorkflowServiceMetadata TestWorkflowServiceMetad… TestTSCBWithDynamicSettings · introduced test · go.temporal.io/server/common/circuitbreaker/TestTSCBWithDynamicSettings TestTSCBWithDynamicSetti… TestNewRealClock_NewTimer · introduced test · go.temporal.io/server/common/clock/TestNewRealClock_NewTimer TestNewRealClock_NewTime… TestNewRealClock_NewTimer_Stop · introduced test · go.temporal.io/server/common/clock/TestNewRealClock_NewTimer_Stop TestNewRealClock_NewTime… TestNewRealClock_Now · introduced test · go.temporal.io/server/common/clock/TestNewRealClock_Now TestNewRealClock_Now TestDeepCopy_OtherReferenceTypes_Nil · introduced test · go.temporal.io/server/common/dynamicconfig/TestDeepCopy_OtherReferenceTypes_Nil TestDeepCopy_OtherRefere… TestMutexMapBaggage · introduced test · go.temporal.io/server/common/metrics/TestBaggageBenchSuite/TestMutexMapBaggage TestMutexMapBaggage TestSyncMapBaggage · introduced test · go.temporal.io/server/common/metrics/TestBaggageBenchSuite/TestSyncMapBaggage TestSyncMapBaggage TestHandleBusyWorkflow_SubmitsToExecutionQueueScheduler · introduced test · go.temporal.io/server/common/tasks/TestExecutionAwareSchedulerSuite/TestHandleBusyWorkflow_SubmitsToExecutionQueueScheduler TestHandleBusyWorkflow_S… TestStartStop_Disabled · introduced test · go.temporal.io/server/common/tasks/TestExecutionAwareSchedulerSuite/TestStartStop_Disabled TestStartStop_Disabled TestStartStop_Enabled · introduced test · go.temporal.io/server/common/tasks/TestExecutionAwareSchedulerSuite/TestStartStop_Enabled TestStartStop_Enabled TestTrySubmit_AddsToExistingQueueSuccessfully · introduced test · go.temporal.io/server/common/tasks/TestExecutionAwareSchedulerSuite/TestTrySubmit_AddsToExistingQueueSuccessfully TestTrySubmit_AddsToExis… TestHasQueue · introduced test · go.temporal.io/server/common/tasks/TestExecutionQueueSchedulerSuite/TestHasQueue TestHasQueue TestParallelTrySubmit_DifferentWorkflows · introduced test · go.temporal.io/server/common/tasks/TestExecutionQueueSchedulerSuite/TestParallelTrySubmit_DifferentWorkflows TestParallelTrySubmit_Di… TestParallelTrySubmit_SameWorkflow · introduced test · go.temporal.io/server/common/tasks/TestExecutionQueueSchedulerSuite/TestParallelTrySubmit_SameWorkflow TestParallelTrySubmit_Sa… TestSequentialExecution_DifferentWorkflows · introduced test · go.temporal.io/server/common/tasks/TestExecutionQueueSchedulerSuite/TestSequentialExecution_DifferentWorkflows TestSequentialExecution_… TestSequentialExecution_SameWorkflow · introduced test · go.temporal.io/server/common/tasks/TestExecutionQueueSchedulerSuite/TestSequentialExecution_SameWorkflow TestSequentialExecution_… TestTrySubmit_ExistingQueue · introduced test · go.temporal.io/server/common/tasks/TestExecutionQueueSchedulerSuite/TestTrySubmit_ExistingQueue TestTrySubmit_ExistingQu… TestTrySubmit_Success · introduced test · go.temporal.io/server/common/tasks/TestExecutionQueueSchedulerSuite/TestTrySubmit_Success TestTrySubmit_Success TestAPIPrioritiesOrdered · introduced test · go.temporal.io/server/service/matching/configs/TestQuotasSuite/TestAPIPrioritiesOrdered TestAPIPrioritiesOrdered TestAPIToPriorityMapping · introduced test · go.temporal.io/server/service/matching/configs/TestQuotasSuite/TestAPIToPriorityMapping TestAPIToPriorityMapping Focused concept · execution_aware_scheduler.go ×1 · 3 introduced LOC execution_aware_schedule…
Graph controls are ready.
Interactive rendering requires JavaScript and WebGL. Use the native relationship evidence on this page while the interactive map is unavailable.
JavaScript is disabled; use the native relationship evidence on this page to explore the same evidence.
Native relationship evidence
Every exact file and test below is linked only from the concept that introduces it.
Introduced tests
Every collected test enters the hierarchy at exactly one concept.
1 test introduced at this concept.
Introduced code
Every collected source range enters the hierarchy at exactly one concept.
1 file ranked by introduced lines: 3 introduced LOC across 1 ranges.
Expand a file to inspect source; the > gutter marks introduced lines.
go.temporal.io/server/common/tasks/execution_aware_scheduler.go 3 introduced LOC · 1 range
Open complete file
94
func ( s * ExecutionAwareScheduler [ T ]) TrySubmit ( task T ) bool {
95
if s . shouldRouteToExecutionQueueScheduler ( task ) {
97
>
return true
98
>
}
99
// executionQueueScheduler is full, fall through to base scheduler.
100
}