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.

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


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 details)

Uploaded Source

Built Distribution

File details

Details for the file kafka_temporal_mapper_client-0.1.1.tar.gz.

File metadata

File hashes

Hashes for kafka_temporal_mapper_client-0.1.1.tar.gz
Algorithm Hash digest
SHA256 7da24cb0aba1af636ce3dfe60a34e8d3942c82f10adfc71ead8d109af348a09c
MD5 f2a267c778740f1b44277fcac429eb22
BLAKE2b-256 92c5d53f7740eef0b8acabfcbf3d0b6c6ee171a8cdbaf6c59dc7a35949f46bb5

See more details on using hashes here.

File details

Details for the file kafka_temporal_mapper_client-0.1.1-py3-none-any.whl.

File metadata

File hashes

Hashes for kafka_temporal_mapper_client-0.1.1-py3-none-any.whl
Algorithm Hash digest
SHA256 ded108009756ffad5d4762ed74278a43542ac9cb6bb9fd37cabd626bca5ede9b
MD5 1c5eb3efce8a6885c9b7ea9089bcab3e
BLAKE2b-256 1c72630802be3d1f631a6e6484e3f351a71a323ad299846401cf57db6b2a4e1f

See more details on using hashes here.

Supported by

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