transforms.api.IncrementalTransformContext

class transforms.api.IncrementalTransformContext(is_incremental, snapshot_inputs, *args)

TransformContext with added functionality for incremental computation.

abort_job()

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

History

• Added in version 1.7.0.

property auth_header

The auth header used to run the transform.

• Type: str ↗

property environment

The list of solved conda packages.

• Type: List[str ↗]

property fallback_branches

The fallback branches configured when running the transform.

• Type: List[str ↗]

property is_incremental

If the transform is running incrementally.

• Type: bool ↗

property parameters

Transform parameters.

• Type: dict ↗ of (str ↗, any)

property spark_session

The Spark session used to run the transform.

• Type: pyspark.sql.SparkSession ↗