Matthew Millendorf
06/16/2022, 3:51 PMKevin Kho
06/16/2022, 5:02 PMMatthew Millendorf
06/16/2022, 6:28 PMKevin Kho
06/16/2022, 6:29 PMMatthew Millendorf
06/16/2022, 6:31 PMKevin Kho
06/16/2022, 6:32 PMMatthew Millendorf
06/16/2022, 6:32 PMKevin Kho
06/16/2022, 6:35 PMprefect run --name flow_name --project project-name --watch
to see if an agent picks it up? There will be a warning raised if there are no agents with matching labelsMatthew Millendorf
06/16/2022, 6:36 PMKevin Kho
06/16/2022, 6:42 PMMatthew Millendorf
06/16/2022, 6:43 PMWatching flow run execution...
└── 14:40:51 | INFO | Entered state <Scheduled>: Flow run scheduled.
└── 14:40:54 | INFO | Entered state <Submitted>: Submitted for execution
└── 14:41:22 | INFO | Downloading flow from <s3://raptormaps-prefect-flows/leo-qa/2022-05-31t21-13-30-615824-00-00>
└── 14:41:24 | INFO | Flow successfully downloaded. ETag: "a406a2539dad5330f88c0e40994a5e55", LastModified: 2022-05-31T21:13:34+00:00, VersionId: None
└── 14:41:24 | INFO | Entered state <Failed>: Failed to load and execute Flow's environment: FlowStorageError('An error occurred while unpickling the flow:\n TypeError("\'NoneType\' object is not callable")\nThis may be due to one of the following version mismatches between the flow build and execution environments:\n - cloudpickle: (flow built with \'1.6.0\', currently running with \'2.0.0\')\n - python: (flow built with \'3.6.8\', currently running with \'3.7.12\')')
Flow run failed!
Kevin Kho
06/16/2022, 7:01 PMMatthew Millendorf
06/16/2022, 7:03 PMKevin Kho
06/16/2022, 7:03 PMMatthew Millendorf
06/16/2022, 7:03 PMKevin Kho
06/16/2022, 7:03 PMECSRun(image="prefecthq/prefect:latest-python3.6")
something like that.
You can view which one picked it up by hunting for it in the Agents tab