A client library to send subscribe and notify workflow events to the kafka-temporal-mapper server.
Project description
Kafka-Temporal Mapper Client
Kafka-Temporal mapper client facilitates the interaction between the workflows and the Kafka-Temporal mapper server. This library is used by the workflows and provides methods for publishing of the workflow and mapping events.
The client provides two methods:
- subscribe: used to subscribe a workflow to the execution of another workflow.
- notify: used by a workflow to notify the termination of its execution.
Installation
pip install kafka_temporal_mapper_client
Usage
To use this library for notifying or subscribing:
from kafka_temporal_mapper.client import KafkaTemporalClient
ktc = KafkaTemporalClient()
# subscribe workflow B to workflow A using a part of A's results as argument (@b.c)
ktc.subscribe('WorkflowB', [{'name':'WorkflowA', 'args': {"a":"hello", "b":"@b.c"}}])
# notify workflow A execution and its results
ktc.notify('WorkflowA', {"a":"hello", "b": {"c": "world"}})
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for kafka_temporal_mapper_client-0.1.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 7da24cb0aba1af636ce3dfe60a34e8d3942c82f10adfc71ead8d109af348a09c |
|
MD5 | f2a267c778740f1b44277fcac429eb22 |
|
BLAKE2b-256 | 92c5d53f7740eef0b8acabfcbf3d0b6c6ee171a8cdbaf6c59dc7a35949f46bb5 |
Close
Hashes for kafka_temporal_mapper_client-0.1.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ded108009756ffad5d4762ed74278a43542ac9cb6bb9fd37cabd626bca5ede9b |
|
MD5 | 1c5eb3efce8a6885c9b7ea9089bcab3e |
|
BLAKE2b-256 | 1c72630802be3d1f631a6e6484e3f351a71a323ad299846401cf57db6b2a4e1f |