Arnas
07/08/2022, 8:06 AMfrom prefect import task, Flow, Parameter
@task
def task_function(in_list_size=10, out_list_size=4):
in_list = list(range(in_list_size))
print(f">>> Input list: {in_list}")
out_list = list(range(out_list_size))
print(f">>> Output list: {out_list}")
diff_list = [i for i in in_list if i not in out_list]
print(f">>> Result list: {diff_list}")
return diff_list
with Flow("Test Flow") as flow:
in_list_size = Parameter("input_list_size", default=10)
out_list_size = Parameter("output_list_size", default=4)
result = task_function(in_list_size=in_list_size, out_list_size=out_list_size)
flow.register(project_name="tutorial")
if __name__ == "__main__":
flow.run()
Trying to figure out where the problem is - guessing something is wrong on the Local Agent side?Anna Geller
07/08/2022, 11:05 AMflow.register(project_name="tutorial")
from your flow code and try the CLI instead
prefect register --project xxx -p yourflow.py
Arnas
07/08/2022, 11:24 AMProcess PID 1628 returned non-zero exit code 3221225477!
It's just a little strange, because I am able to run the flow without any issues from the command line (even using the same conda environment as the Local Agent)Anna Geller
07/08/2022, 11:39 AMfrom prefect import task, Flow, Parameter
@task
def task_function(in_list_size=10, out_list_size=4):
in_list = list(range(in_list_size))
print(f">>> Input list: {in_list}")
out_list = list(range(out_list_size))
print(f">>> Output list: {out_list}")
diff_list = [i for i in in_list if i not in out_list]
print(f">>> Result list: {diff_list}")
return diff_list
with Flow("Test Flow") as flow:
in_list_size = Parameter("input_list_size", default=10)
out_list_size = Parameter("output_list_size", default=4)
result = task_function(in_list_size=in_list_size, out_list_size=out_list_size)
if __name__ == "__main__":
flow.run()
Arnas
07/08/2022, 11:47 AMAnna Geller
07/08/2022, 11:53 AMMichael Ng
08/16/2022, 6:40 PMArnas
08/16/2022, 9:55 PM