Execution

Data lineage

Follow each callable's declared inputs and outputs. Escape outputs are external declarations, not dataframe columns.

Illustration only: keys, values, results, and row counts are placeholders, not calculated data. No spec are executed.

Stage 1 / 1 independent step

Read Pump Telemetry

READ

Sourcepump_telemetry_dataset

The read callable supplies the declared columns.

Read

Output Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	discharge_pressurefloat	flow_ratefloat	bearing_temperaturefloat	vibration_rmsfloat	motor_powerfloat
Key 1	Key 1	Key 1	Key 1	Result 1	Result 1	Result 1	Result 1	Result 1
Key 2	Key 2	Key 2	Key 2	Result 2	Result 2	Result 2	Result 2	Result 2
Key 3	Key 3	Key 3	Key 3	Result 3	Result 3	Result 3	Result 3	Result 3

Declared columns shown with three placeholder rows. Actual row counts are not known.

Declared schema and dependencies

Entity: pump_telemetry · Dataset: pump_telemetry_dataset

Depends on: No preceding steps

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Dimension	timestamp	datetime	Observation key
Output	discharge_pressure	float	This step
Output	flow_rate	float	This step
Output	bearing_temperature	float	This step
Output	vibration_rms	float	This step
Output	motor_power	float	This step

Stage 2 / 5 independent steps

Maximum

AGGREGATE

Input Dataset: pump_datasetIllustrative rows
plantstring	production_linestring	pumpstring	bearing_temperaturefloat
Key 1	Key 1	Key 1	Value 1
Key 1	Key 1	Key 1	Value 2
Key 1	Key 1	Key 1	Value 3

Aggregate

Output Dataset: pump_datasetIllustrative rows
plantstring	production_linestring	pumpstring	bearing_temperature_maxfloat
Key 1	Key 1	Key 1	Result 1

Illustrative grouping: three placeholder rows become one group. Actual grouping and row counts are not known.

Declared schema and dependencies

Entity: pump · Dataset: pump_dataset

Depends on: Step 1

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Input	bearing_temperature	float	Step 1
Output	bearing_temperature_max	float	This step

Bearing Temperature Delta

VECTORIZE

Input Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	bearing_temperaturefloat
Key 1	Key 1	Key 1	Key 1	Value 1
Key 2	Key 2	Key 2	Key 2	Value 2
Key 3	Key 3	Key 3	Key 3	Value 3

Vectorize

Output Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	bearing_temperature_deltafloat
Key 1	Key 1	Key 1	Key 1	Result 1
Key 2	Key 2	Key 2	Key 2	Result 2
Key 3	Key 3	Key 3	Key 3	Result 3

Declared columns shown with three placeholder rows. Actual row counts are not known.

Declared schema and dependencies

Entity: pump_telemetry · Dataset: pump_telemetry_dataset

Depends on: Step 1

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Dimension	timestamp	datetime	Observation key
Input	bearing_temperature	float	Step 1
Output	bearing_temperature_delta	float	This step

Optimize Pump Operating Point

VECTORIZE

Input Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	discharge_pressurefloat	flow_ratefloat	motor_powerfloat	bearing_temperaturefloat	vibration_rmsfloat
Key 1	Key 1	Key 1	Key 1	Value 1	Value 1	Value 1	Value 1	Value 1
Key 2	Key 2	Key 2	Key 2	Value 2	Value 2	Value 2	Value 2	Value 2
Key 3	Key 3	Key 3	Key 3	Value 3	Value 3	Value 3	Value 3	Value 3

Vectorize

Output Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	operating_point_recommendationobject
Key 1	Key 1	Key 1	Key 1	Result 1
Key 2	Key 2	Key 2	Key 2	Result 2
Key 3	Key 3	Key 3	Key 3	Result 3

Declared columns shown with three placeholder rows. Actual row counts are not known.

Declared schema and dependencies

Entity: pump_telemetry · Dataset: pump_telemetry_dataset

Depends on: Step 1

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Dimension	timestamp	datetime	Observation key
Input	discharge_pressure	float	Step 1
Input	flow_rate	float	Step 1
Input	motor_power	float	Step 1
Input	bearing_temperature	float	Step 1
Input	vibration_rms	float	Step 1
Output	operating_point_recommendation	object	This step

Pressure Flow Efficiency

VECTORIZE

Input Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	discharge_pressurefloat	flow_ratefloat	motor_powerfloat
Key 1	Key 1	Key 1	Key 1	Value 1	Value 1	Value 1
Key 2	Key 2	Key 2	Key 2	Value 2	Value 2	Value 2
Key 3	Key 3	Key 3	Key 3	Value 3	Value 3	Value 3

Vectorize

Output Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	pressure_flow_efficiencyfloat
Key 1	Key 1	Key 1	Key 1	Result 1
Key 2	Key 2	Key 2	Key 2	Result 2
Key 3	Key 3	Key 3	Key 3	Result 3

Declared columns shown with three placeholder rows. Actual row counts are not known.

Declared schema and dependencies

Entity: pump_telemetry · Dataset: pump_telemetry_dataset

Depends on: Step 1

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Dimension	timestamp	datetime	Observation key
Input	discharge_pressure	float	Step 1
Input	flow_rate	float	Step 1
Input	motor_power	float	Step 1
Output	pressure_flow_efficiency	float	This step

Vibration Delta From Previous

VECTORIZE

Input Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	vibration_rmsfloat
Key 1	Key 1	Key 1	Key 1	Value 1
Key 2	Key 2	Key 2	Key 2	Value 2
Key 3	Key 3	Key 3	Key 3	Value 3

Vectorize

Output Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	vibration_deltafloat
Key 1	Key 1	Key 1	Key 1	Result 1
Key 2	Key 2	Key 2	Key 2	Result 2
Key 3	Key 3	Key 3	Key 3	Result 3

Declared columns shown with three placeholder rows. Actual row counts are not known.

Declared schema and dependencies

Entity: pump_telemetry · Dataset: pump_telemetry_dataset

Depends on: Step 1

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Dimension	timestamp	datetime	Observation key
Input	vibration_rms	float	Step 1
Output	vibration_delta	float	This step

Stage 3 / 6 independent steps

Extract Recommendation Value

VECTORIZE

Input Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	operating_point_recommendationobject
Key 1	Key 1	Key 1	Key 1	Value 1
Key 2	Key 2	Key 2	Key 2	Value 2
Key 3	Key 3	Key 3	Key 3	Value 3

Vectorize

Output Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	convergedboolean
Key 1	Key 1	Key 1	Key 1	Result 1
Key 2	Key 2	Key 2	Key 2	Result 2
Key 3	Key 3	Key 3	Key 3	Result 3

Declared columns shown with three placeholder rows. Actual row counts are not known.

Declared schema and dependencies

Entity: pump_telemetry · Dataset: pump_telemetry_dataset

Depends on: Step 1, Step 4

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Dimension	timestamp	datetime	Observation key
Input	operating_point_recommendation	object	Step 4
Output	converged	boolean	This step

Extract Recommendation Value

VECTORIZE

Input Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	operating_point_recommendationobject
Key 1	Key 1	Key 1	Key 1	Value 1
Key 2	Key 2	Key 2	Key 2	Value 2
Key 3	Key 3	Key 3	Key 3	Value 3

Vectorize

Output Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	energy_cost_scorefloat
Key 1	Key 1	Key 1	Key 1	Result 1
Key 2	Key 2	Key 2	Key 2	Result 2
Key 3	Key 3	Key 3	Key 3	Result 3

Declared columns shown with three placeholder rows. Actual row counts are not known.

Declared schema and dependencies

Entity: pump_telemetry · Dataset: pump_telemetry_dataset

Depends on: Step 1, Step 4

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Dimension	timestamp	datetime	Observation key
Input	operating_point_recommendation	object	Step 4
Output	energy_cost_score	float	This step

Extract Recommendation Value

VECTORIZE

Input Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	operating_point_recommendationobject
Key 1	Key 1	Key 1	Key 1	Value 1
Key 2	Key 2	Key 2	Key 2	Value 2
Key 3	Key 3	Key 3	Key 3	Value 3

Vectorize

Output Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	recommended_discharge_pressurefloat
Key 1	Key 1	Key 1	Key 1	Result 1
Key 2	Key 2	Key 2	Key 2	Result 2
Key 3	Key 3	Key 3	Key 3	Result 3

Declared columns shown with three placeholder rows. Actual row counts are not known.

Declared schema and dependencies

Entity: pump_telemetry · Dataset: pump_telemetry_dataset

Depends on: Step 1, Step 4

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Dimension	timestamp	datetime	Observation key
Input	operating_point_recommendation	object	Step 4
Output	recommended_discharge_pressure	float	This step

Extract Recommendation Value

VECTORIZE

Input Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	operating_point_recommendationobject
Key 1	Key 1	Key 1	Key 1	Value 1
Key 2	Key 2	Key 2	Key 2	Value 2
Key 3	Key 3	Key 3	Key 3	Value 3

Vectorize

Output Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	recommended_flow_ratefloat
Key 1	Key 1	Key 1	Key 1	Result 1
Key 2	Key 2	Key 2	Key 2	Result 2
Key 3	Key 3	Key 3	Key 3	Result 3

Declared columns shown with three placeholder rows. Actual row counts are not known.

Declared schema and dependencies

Entity: pump_telemetry · Dataset: pump_telemetry_dataset

Depends on: Step 1, Step 4

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Dimension	timestamp	datetime	Observation key
Input	operating_point_recommendation	object	Step 4
Output	recommended_flow_rate	float	This step

Normalize Health Signal

VECTORIZE

Input Dataset: pump_datasetIllustrative rows
plantstring	production_linestring	pumpstring	bearing_temperature_maxfloat
Key 1	Key 1	Key 1	Value 1
Key 2	Key 2	Key 2	Value 2
Key 3	Key 3	Key 3	Value 3

Vectorize

Output Dataset: pump_datasetIllustrative rows
plantstring	production_linestring	pumpstring	health_signal_normalizedfloat
Key 1	Key 1	Key 1	Result 1
Key 2	Key 2	Key 2	Result 2
Key 3	Key 3	Key 3	Result 3

Declared columns shown with three placeholder rows. Actual row counts are not known.

Declared schema and dependencies

Entity: pump · Dataset: pump_dataset

Depends on: Step 2

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Input	bearing_temperature_max	float	Step 2
Output	health_signal_normalized	float	This step

Pump Health Score

VECTORIZE

Input Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	bearing_temperature_deltafloat	vibration_deltafloat	pressure_flow_efficiencyfloat
Key 1	Key 1	Key 1	Key 1	Value 1	Value 1	Value 1
Key 2	Key 2	Key 2	Key 2	Value 2	Value 2	Value 2
Key 3	Key 3	Key 3	Key 3	Value 3	Value 3	Value 3

Vectorize

Output Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	pump_health_scorefloat
Key 1	Key 1	Key 1	Key 1	Result 1
Key 2	Key 2	Key 2	Key 2	Result 2
Key 3	Key 3	Key 3	Key 3	Result 3

Declared columns shown with three placeholder rows. Actual row counts are not known.

Declared schema and dependencies

Entity: pump_telemetry · Dataset: pump_telemetry_dataset

Depends on: Step 1, Step 3, Step 5, Step 6

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Dimension	timestamp	datetime	Observation key
Input	bearing_temperature_delta	float	Step 3
Input	vibration_delta	float	Step 6
Input	pressure_flow_efficiency	float	Step 5
Output	pump_health_score	float	This step

Stage 4 / 1 independent step

Write Pump Telemetry

WRITE

Input Dataset: pump_telemetry_datasetIllustrative rows
plantstring	production_linestring	pumpstring	timestampdatetime	recommended_flow_ratefloat	recommended_discharge_pressurefloat	energy_cost_scorefloat	convergedboolean	pressure_flow_efficiencyfloat	bearing_temperature_deltafloat	vibration_deltafloat	pump_health_scorefloat	operating_point_recommendationobject
Key 1	Key 1	Key 1	Key 1	Value 1	Value 1	Value 1	Value 1	Value 1	Value 1	Value 1	Value 1	Value 1
Key 2	Key 2	Key 2	Key 2	Value 2	Value 2	Value 2	Value 2	Value 2	Value 2	Value 2	Value 2	Value 2
Key 3	Key 3	Key 3	Key 3	Value 3	Value 3	Value 3	Value 3	Value 3	Value 3	Value 3	Value 3	Value 3

Write

Write destinationpump_telemetry_dataset

Consumes the input columns; produces no analytical features.

Write boundary: no new analytical columns.

Declared schema and dependencies

Entity: pump_telemetry · Dataset: pump_telemetry_dataset

Depends on: Step 1, Step 3, Step 4, Step 5, Step 6, Step 7, Step 8, Step 9, Step 10, Step 12

Declared schema (not illustrative values)
Role	Column	Type	Producer
Dimension	plant	string	Observation key
Dimension	production_line	string	Observation key
Dimension	pump	string	Observation key
Dimension	timestamp	datetime	Observation key
Input	recommended_flow_rate	float	Step 10
Input	recommended_discharge_pressure	float	Step 9
Input	energy_cost_score	float	Step 8
Input	converged	boolean	Step 7
Input	pressure_flow_efficiency	float	Step 5
Input	bearing_temperature_delta	float	Step 3
Input	vibration_delta	float	Step 6
Input	pump_health_score	float	Step 12
Input	operating_point_recommendation	object	Step 4

Playback follows dependency stages. Callables in the same stage are independent.