A local client for connecting and working with Coalesce
Project description
shipyard-coalesce
Description
A local client to trigger Coalesce job's and check statuses of past runs
Installation
python3 -m pip install shipyard-coalesce
Usage
Establish the client by running the following
from shipyard_coalesce import CoalesceClient
client = CoalesceClient(access_token = '<your_access_token>')
Trigger syncs
The following arguments are required for the trigger_sync
function:
- environment_id
- snowflake_username
- snowflake_password
- snowflake_role
The following arguments are optional:
- snowflake_warehouse
- include_nodes_selector
- exclude_nodes_selector
- parallelism
- job_id
response = client.trigger_sync(environment_id = environment_id, snowflake_username = snowflake_username, snowflake_password = snowflake_password, snowflake_role = snowflake_role)
print(response)
Sync Status
To verify the sync status, you will need the runID
, which is obtained in the response from the trigger_sync
method.
run_id = response['runCounter']
status = client.get_run_status(run_id)
print(status.text)
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 shipyard_coalesce-0.2.2a0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | e688fd2199d08291f43c8c47bd73eaebcb7950a80e24a32ec0694d8ec0b0ad82 |
|
MD5 | bb213bbf30179c40852e383bfd1c42b7 |
|
BLAKE2b-256 | 940aa4168769a45198ff10a123fe2ca4923aa5771e922e1567d13b20f3411682 |
Close
Hashes for shipyard_coalesce-0.2.2a0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ff44ecba86b61ba00d6c3b9fd84553cf1c1f77f95e1e4f5b108e649c880ebdba |
|
MD5 | e8f8ef1aa1343efb42e8286eaf083f64 |
|
BLAKE2b-256 | af929e4c12d7996557007a2c2d0a9cb44461284dec837640c80f88ac24e96f98 |