Enhanced, asyncio-compatible client for AWS Step Functions.
Project description
sfn_workflow_client
Enhanced, asyncio-compatible client for AWS Step Functions.
Features:
- Trigger new executions
- Query for state machine execution status
- Wait for an execution to complete
- Fetch execution history
Table of Contents:
Installation
sfn_workflow_client requires Python 3.6 or above.
pip install sfn_workflow_client
Guide
from sfn_workflow_client.enums import ExecutionStatus
from sfn_workflow_client.workflow import Workflow
# Initialize a workflow client
workflow = Workflow("my-state-machine")
# Fetch all executions
collection = await workflow.executions.fetch()
# Fetch currently running executions
collection = await workflow.executions.fetch(status=ExecutionStatus.running)
# Start a new execution
execution = await workflow.executions.create().start()
# Start a new execution and wait until it completes (useful for tests)
execution = await workflow.executions.start_sync()
# Find an execution by trace ID (for tests)
execution = await workflow.executions.fetch().find_by_trace_id("abc")
# Fetch the event history of an execution
events = await execution.events.fetch()
Development
To develop sfn_workflow_client, install dependencies and enable the pre-commit hook:
pip install pre-commit tox
pre-commit install
To run functional tests, you need to create an AWS IAM role with permissions to:
- Create/update/delete state machines
- Start/stop executions
Set the following environment variables:
AWS_ACCOUNT_ID
AWS_ACCESS_KEY_ID
AWS_SECRET_ACCESS_KEY
AWS_DEFAULT_REGION
AWS_IAM_ROLE_ARN
To run tests:
tox
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
sfn_workflow_client-0.4.1.tar.gz
(11.7 kB
view hashes)
Built Distribution
Close
Hashes for sfn_workflow_client-0.4.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 687f36c8d7572f87449a6e9864815bb8682169e1b0931668fa30962897ba106f |
|
MD5 | bcec10a84b3820daf2b9bd9fca351170 |
|
BLAKE2b-256 | 2b306dee0935be6c8aaf00c03551b0a311ad321f2083b1ebd8ffb6c21e6cf810 |
Close
Hashes for sfn_workflow_client-0.4.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 6c15168795abb135140a81b9bd98329d6e25edbde572245125b84cbbfb57fe53 |
|
MD5 | 37bb1abc0af7bec2e83c2be0cefde9c9 |
|
BLAKE2b-256 | 58c7c6dc2e6d29bb2bf09aa5b64367d365ad83e23f17b9a65d347cbe805665b2 |