Hello! I am trying to run a simple spark-operator job on prefect server by following the instructions provided here: https://github.com/tardunge/prefect-spark-on-k8s-operator/blob/main/README.md. Attaching the flow and spark-operator yaml to this message. When I try to run the job locally (python3.11 job.py), I run into "prefect.exceptions.ScriptError: Script at 'simple-so-k8s-on-prefect.py' encountered an exception: TypeError("Object of type 'FieldInfo' is not JSON serializable")". Attaching entire stack trace for reference. Any idea what's happening? Note: I am running the code inside a container.
Slack Conversation
n
Nate
04/30/2024, 8:18 PM
haven’t looked deeply but i recognize that error as “someone put a v2 pydantic field on a v1 model” error
Nate
04/30/2024, 8:19 PM
so i would guess in the definition of that SparkApplication block (Block is currently always a v1 BaseModel subclass), someone is putting a Field that comes from pydantic 2
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.