transforms.api.LightweightContext

class transforms.api.LightweightContext

A context object that can optionally be injected into the compute function of a lightweight transform.

Can be accessed by adding a ctx argument to the compute function as shown below:

Copied!
1
2
3
>>> @transform.using(...)
... def compute(ctx, ...):
...     ...

Equivalent to transforms.api.TransformContext for single node compute.

abort_job()

Aborts the job and ends execution. This will abort all output transactions.

property auth_header

The auth header used to run the transform.

property is_incremental

Whether the transform is running incrementally.