# {py:mod}`ovo.core.scheduler.simple_queue_mixin`

```{py:module} ovo.core.scheduler.simple_queue_mixin
```

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin
:allowtitles:
```

## Module Contents

### Classes

````{list-table}
:class: autosummary longtable
:align: left

* - {py:obj}`SimpleQueueMixin <ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin>`
  - ```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin
    :summary:
    ```
* - {py:obj}`TaskQueue <ovo.core.scheduler.simple_queue_mixin.TaskQueue>`
  - ```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.TaskQueue
    :summary:
    ```
````

### API

`````{py:class} SimpleQueueMixin
:canonical: ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin

Bases: {py:obj}`abc.ABC`

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin
```

````{py:method} has_queue()
:canonical: ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.has_queue

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.has_queue
```

````

````{py:method} _queue_get_address()
:canonical: ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin._queue_get_address

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin._queue_get_address
```

````

````{py:method} queue_put(job_id: str, task: typing.Any)
:canonical: ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.queue_put

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.queue_put
```

````

````{py:method} queue_size(job_id: str = None) -> int | None
:canonical: ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.queue_size

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.queue_size
```

````

````{py:method} connect_to_queue(host: str = None, port: int = None)
:canonical: ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.connect_to_queue

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.connect_to_queue
```

````

````{py:method} create_queue_server(host: str = None, port: int = None)
:canonical: ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.create_queue_server

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.create_queue_server
```

````

````{py:method} queue_worker(queue, queue_id)
:canonical: ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.queue_worker

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.queue_worker
```

````

````{py:method} queue_run_task(job_id: str, task: typing.Any)
:canonical: ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.queue_run_task
:abstractmethod:

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin.queue_run_task
```

````

````{py:method} _queue_get_auth_key()
:canonical: ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin._queue_get_auth_key

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.SimpleQueueMixin._queue_get_auth_key
```

````

`````

`````{py:class} TaskQueue()
:canonical: ovo.core.scheduler.simple_queue_mixin.TaskQueue

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.TaskQueue
```

```{rubric} Initialization
```

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.TaskQueue.__init__
```

````{py:method} put(item)
:canonical: ovo.core.scheduler.simple_queue_mixin.TaskQueue.put

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.TaskQueue.put
```

````

````{py:method} get()
:canonical: ovo.core.scheduler.simple_queue_mixin.TaskQueue.get

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.TaskQueue.get
```

````

````{py:method} get_job_ids()
:canonical: ovo.core.scheduler.simple_queue_mixin.TaskQueue.get_job_ids

```{autodoc2-docstring} ovo.core.scheduler.simple_queue_mixin.TaskQueue.get_job_ids
```

````

`````