omni.flux.job_queue.core#

  • SPDX-FileCopyrightText: Copyright (c) 2025 NVIDIA CORPORATION & AFFILIATES. All rights reserved.

  • SPDX-License-Identifier: Apache-2.0

  • Licensed under the Apache License, Version 2.0 (the “License”);

  • you may not use this file except in compliance with the License.

  • You may obtain a copy of the License at

  • https://www.apache.org/licenses/LICENSE-2.0

  • Unless required by applicable law or agreed to in writing, software

  • distributed under the License is distributed on an “AS IS” BASIS,

  • WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

  • See the License for the specific language governing permissions and

  • limitations under the License.

class omni.flux.job_queue.core.FluxJobQueueCoreExtension#

Own the process-wide queue and apply-handler runtime.

on_shutdown() → None#

Release the shared queue and begin apply-runtime cleanup.

on_startup(_ext_id: str) → None#

Recover the shared queue and create its apply runtime.

Parameters:

_ext_id – Kit extension identifier.

Raises:

RuntimeError – If the app documents path cannot be resolved.

omni.flux.job_queue.core.get_job_queue() → QueueInterface#

Return the process-wide job queue.

Returns:

The shared queue interface.

Raises:

RuntimeError – If the extension has not started.