Skip to main content

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.


pip install kafka_temporal_mapper_client


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

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

kafka_temporal_mapper_client-0.1.1.tar.gz (16.6 kB view hashes)

Uploaded source

Built Distribution

Supported by

AWS AWS Cloud computing Datadog Datadog Monitoring Fastly Fastly CDN Google Google Object Storage and Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page