Orchestra SDK for updating self-hosted Tasks.
Project description
Orchestra Python SDK
This is a lightweight SDK that allows Orchestra to interact with self-hosted applications (Tasks).
The basic premise is for your self-hosted Task to send back status updates and logs to Orchestra. This is done via HTTP requests. The Task is started by Orchestra.
Guide
Firstly, install the package:
pip install orchestra-sdk
The package requires the following environment variable to be set manually:
ORCHESTRA_API_KEY
: The API key to connect to Orchestra. This can be found in your settings page.
Orchestra will automatically set the following environment variables when the Task is triggered:
ORCHESTRA_WEBHOOK_URL
: The URL to send status updates toORCHESTRA_TASK_RUN_ID
: The UUID of the Task being executedORCHESTRA_PIPELINE_RUN_ID
: The UUID of the Pipeline Run that the Task is part of
To use the package in your code:
from orchestra_sdk.decorators import orchestra_run
@orchestra_run()
def my_function(arg1, arg2=1):
print("Running complex process")
Summary
- The decorator will firstly read and validate the environment variables
- It will send a
RUNNING
status update to Orchestra - Your function will then run
- If an exception is raised, the decorator will send a
FAILED
status update to Orchestra - If the function finishes without an error being raised, regardless of the return value, the decorator will send a
SUCCEEDED
status update to Orchestra
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
orchestra_sdk-0.0.10.tar.gz
(8.0 kB
view hashes)
Built Distribution
Close
Hashes for orchestra_sdk-0.0.10-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | cc9279b9ff93c5b25f6317bfe3547bc7a397e2b85c6918eb23459c822c9ca513 |
|
MD5 | 2fcf4ea3e7ce3d455b9e93f0e818f413 |
|
BLAKE2b-256 | d85f1de8ca88fa4f3f61564700eedc4956a061307c41d0186e8ab87230f9ffdd |