fix: pipeline id keyerr in tools.py

Signed-off-by: Avik Basu <[email protected]>
numaproj · Jan 23, 2024 · fbf171f · fbf171f
1 parent add642c
commit fbf171f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/numalogic/udfs/tools.py b/numalogic/udfs/tools.py
@@ -98,7 +98,7 @@ def make_stream_payload(
  return StreamPayload(
  uuid=data_payload["uuid"],
  config_id=data_payload["config_id"],
- pipeline_id=data_payload["pipeline_id"],
+ pipeline_id=data_payload.get("pipeline_id", "default"),
  composite_keys=keys,
  data=np.ascontiguousarray(raw_df, dtype=np.float32),
  raw_data=np.ascontiguousarray(raw_df, dtype=np.float32),