Zaku Example

This example shows you how upload and download data

from zaku import TaskQ

queue = TaskQ()

{'host': 'http://localhost:9000', 'name': 'jq-121c8aad-7d85-4cfd-9116-7452744a0257', 'ttl': 5, 'no_init': None}

Now we can add a few jobs to the queue

queue.add({"seed": 100, "data": [1, 2, 3]})

If you want more control over the job id, you can specify it explicitly using the key argument:

count = 0
queue.add({"seed": 200, "data": [1, 2, 3]}, key=count)

job_id, job_config = queue.take()

a859a910-9bcb-4670-afd7-9d9896ae022f {'seed': 100, 'data': [1, 2, 3]}

Now if we take again, it gives us a different one

job_id, job_config = queue.take()

0 {'seed': 200, 'data': [1, 2, 3]}

Since we only added two jobs, the queue should be empty now. Let’s check!

result = queue.take()

doc.print(f"result is: [{result}]")

result is: [None]