Dekel R
03/14/2022, 9:21 AMflow.run_config = VertexRun(scheduling={'timeout': '3600s'},
machine_type='n2-highcpu-80', labels=["ml"],
service_account=PREFECT_SERVICRE_ACCOUNT)
It works without the scheduling parameter - I added it and used this documentation -
https://docs.prefect.io/orchestration/flow_config/run_configs.html#vertexrun
Now when registering to Prefect cloud and running I get this error -
Parameter to MergeFrom() must be instance of same class: expected google.protobuf.Duration got str.
Am I missing something?
ThanksAnna Geller
03/14/2022, 9:54 AMgoogle.protobuf.Duration
? But this would be surprising since based on this:
The JSON representation for Duration is a String that ends in s to indicate seconds and is preceded by the number of seconds, with nanoseconds expressed as fractional seconds.
All we do with this, it seems, on the agent side is passing it to the Vertex task definition in this JSON format https://github.com/PrefectHQ/prefect/blob/master/src/prefect/agent/vertex/agent.py#L170-L171Marvin
03/14/2022, 9:57 AM