Skip to content

Commit 867be69

Browse files
committed
adapting code to match current pygeoapi
1 parent 57820f7 commit 867be69

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

src/pygeoapi_prefect/manager.py

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -404,9 +404,12 @@ def execute_process(
404404
processor = self.get_processor(process_id)
405405
# https://docs.prefect.io/v3/how-to-guides/deployments/run-deployments#run-a-deployment-from-python
406406
if chosen_mode == ProcessExecutionMode.sync_execute:
407-
# if it's a BaseProcessor type, run our locally deployed flow
408-
# if it's a PrefectProcessor type, run the name of the deployment
409-
# 1. get the name of the deployment
407+
# - if it's a BaseProcessor type, create a flow_run for our locally deployed
408+
# flow and then either run in blocking fashion or non-blocking
409+
# (by leveraging the timeout parameter)
410+
# - if it's a PrefectProcessor type, create a flow run for the provided
411+
# name of the deployment, and either run blocking or non-blocking, like
412+
# the previous
410413
...
411414
else:
412415
...

0 commit comments

Comments
 (0)