Module: task_queue_key

Expand source code

# Copyright (C) 2023-present The Project Contributors
#
# 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
#
#    http://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.

from dataclasses import dataclass
from typing import Type
from cl.runtime.records.dataclasses_extensions import missing
from cl.runtime.records.key_mixin import KeyMixin


@dataclass(slots=True, kw_only=True)
class TaskQueueKey(KeyMixin):
    """
    Run a query on tasks, run all returned tasks sequentially or in parallel, then repeat.

    Notes:
        - A task may run sequentially or in parallel with other tasks
        - A task may run in a different process, thread or machine than the submitting code
          and must be able to acquire the required resources to run in all of these scenarios
        - The queue updates 'status' field of the task as it progresses from its initial Pending state through
          the Running and optionally Paused state and ending in one of Completed, Failed, or Cancelled states
    """

    queue_id: str = missing()
    """Unique task queue identifier."""

    @classmethod
    def get_key_type(cls) -> Type:
        return TaskQueueKey

Classes

class TaskQueueKey (*, queue_id: str = None)

Run a query on tasks, run all returned tasks sequentially or in parallel, then repeat.

Notes

A task may run sequentially or in parallel with other tasks
A task may run in a different process, thread or machine than the submitting code and must be able to acquire the required resources to run in all of these scenarios
The queue updates ‘status’ field of the task as it progresses from its initial Pending state through the Running and optionally Paused state and ending in one of Completed, Failed, or Cancelled states

Expand source code

@dataclass(slots=True, kw_only=True)
class TaskQueueKey(KeyMixin):
    """
    Run a query on tasks, run all returned tasks sequentially or in parallel, then repeat.

    Notes:
        - A task may run sequentially or in parallel with other tasks
        - A task may run in a different process, thread or machine than the submitting code
          and must be able to acquire the required resources to run in all of these scenarios
        - The queue updates 'status' field of the task as it progresses from its initial Pending state through
          the Running and optionally Paused state and ending in one of Completed, Failed, or Cancelled states
    """

    queue_id: str = missing()
    """Unique task queue identifier."""

    @classmethod
    def get_key_type(cls) -> Type:
        return TaskQueueKey

Ancestors

KeyMixin
abc.ABC

Subclasses

TaskQueue

Static methods

def get_key_type() -> Type: Inherited from: KeyMixin.get_key_type

Return key type even when called from a record.

Fields

var queue_id -> str: Unique task queue identifier.