Sven Teresniak
07/20/2020, 12:14 PM2020-07-20T12:09:58.139Z {"message":"Variable \"$input\" got invalid value { flow_id: \"80de1b39-fed7-47ab-a5a5-fc22ac6f87d2\", idempotency_key: \"e82df5c1-d197-46f1-9bb1-f18f9335e0f8\" }; Field \"idempotency_key\" is not defined by type create_flow_run_input.","locations":[{"line":1,"column":10}],"extensions":{"code":"INTERNAL_SERVER_ERROR"}}
Is this a bug?
Every component of my Prefect Cluster (v0.12.4) is running in K8S but its a static setup with every component is one container and everything together in one pod (so everything can communicate using localhost). I have a Dask-Worker pod running and all other flows (not calling other flows) this far are working.Matt Wong-Kemp
07/20/2020, 12:34 PMFlowRunTask
, or you've got a version mismatch? This works OK in cloud.Sven Teresniak
07/20/2020, 12:42 PMprefecthq/*
, e.g. prefecthq/server:0.12.4
for graphql and prefect scheduler, prefecthq/apollo:0.12.4
for apollo, prefecthq/ui:0.12.4
for ui.
For Agent, for the Dask Worker and the Dask Scheduler (master) I have a own image build. Thats because I need some dependencies (Presto, Spark, etc.). But this image is simple and not much more than pip install --no-cache-dir "prefect[$PREFECT_EXTRAS]==$PREFECT_VERSION"
in a python:3
base image. Of course the Version matches and is 0.12.4
, tooidempotency_key
in that structure. And thats exactly what the errormesage said. 😕Matt Wong-Kemp
07/20/2020, 1:24 PMSven Teresniak
07/20/2020, 1:28 PM