Python client for Zeebe workflow engine
Current version is .
$ pip install pyzeebe
Creating a worker
from pyzeebe import ZeebeWorker, create_insecure_channel
channel = create_insecure_channel()
worker = ZeebeWorker(channel)
@worker.task(task_type="my_task")
async def my_task(x: int):
return {"y": x + 1}
await worker.work()
Creating a client
from pyzeebe import ZeebeClient, create_insecure_channel
channel = create_insecure_channel()
client = ZeebeClient(channel)
await client.run_process("my_process")
# Run process with variables:
await client.run_process("my_process", variables={"x": 0})
- python 3.7+
- zeebe-grpc
- grpcio
- protobuf
- oauthlib
- requests-oauthlib
Client <client> Worker <worker> Channels <channels> Decorators <decorators> Exceptions <errors>