Transform.run

Transform.run(*, wait_for_finish=True) → self

Run a transform. If the transform is already running, an exception will be raised.

Parameters:

wait_for_finish: bool, default True Whether to wait for the transform to complete before returning. If waiting, and the transform encounters an error during execution, an error will be raised.

Returns

self (a Transform)

Examples

username = "imathews"
workflow_name = "example_workflow_climate_analysis:x7kh"
transform_name = "join_lat_lon:m9tz"

transform = redivis.transform(f"{username}.{workflow_name}.{transform_name}")
transform.run(wait_for_finish=False)