zaku.types
Type Interfaces#

Here are the basic types for events, html and three.js elements, and others.

class zaku.interfaces.Job[source]#

Bases: SimpleNamespace

created_ts: float#
status: Literal[None, 'in_progress', 'created'] = 'created'#
grab_ts: float = None#
ttl: float = None#
serialize()[source]#
async static deserialize(payload) → Job[source]#
Return type:

Job

async static create_queue(r: Redis, name, *, prefix, smart=True)[source]#
Parameters:

r (Redis) –

async static remove_queue(r: Redis, queue, *, prefix)[source]#
Parameters:

r (Redis) –

static add(r: Redis, queue: str, *, prefix: str, payload: bytes | None = None, job_id: str | None = None, ttl: float | None = None) → Coroutine[source]#
Parameters:

  • r (Redis) –

  • queue (str) –

  • prefix (str) –

  • payload (bytes | None) –

  • job_id (str | None) –

  • ttl (float | None) –

Return type:

Coroutine

async static take(r: Redis, queue, *, prefix) → Tuple[str, Any][source]#
Parameters:

r (Redis) –

Return type:

Tuple[str, Any]

static remove(r: Redis, job_id, queue, *, prefix) → Coroutine[source]#
Parameters:

r (Redis) –

Return type:

Coroutine

static reset_stale(r: Redis, queue, *, prefix, ttl=None)[source]#
Parameters:

r (Redis) –