PgFlow.Flow.Shape (PgFlow v0.4.0)

Copy Markdown View Source

Serializes compiled flow definitions into the upstream camelCase JSON shape consumed by pgflow.ensure_flow_compiled/2, _create_flow_from_shape/2, and _compare_flow_shapes/2.

Defaults and option naming live here so callers share one upstream-compatible representation. Runtime metadata such as flow_type and cron configuration is intentionally excluded from the shape.

Summary

Functions

Builds the upstream flow shape for a compiled definition.

Functions

from_definition(definition)

@spec from_definition(PgFlow.Flow.Definition.t()) :: map()

Builds the upstream flow shape for a compiled definition.

Preserves step declaration order, sorts dependency slugs alphabetically, converts :skip_cascade to "skip-cascade", and wraps input patterns so missing and JSON-null conditions remain distinct.