We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 735f753 commit 31c9d19Copy full SHA for 31c9d19
src/gaiaflow/core/runner.py
@@ -49,17 +49,13 @@ def run(
49
print(f"Running {func_path} with args: {args} and kwargs :{kwargs}")
50
result = func(*args, **kwargs)
51
print("Function result:", result)
52
- print("mode::::", mode, type(mode))
53
if mode == "prod" or mode == "prod_local":
54
# This is needed when we use KubernetesPodOperator and want to
55
# share information via XCOM.
56
_write_xcom_result(result)
57
if mode == "dev_docker":
58
- print("inside dev_docker condition")
59
with open("/tmp/script.out", "wb+") as tmp:
60
pickle.dump(result, tmp)
61
- # print("printing result now:::")
62
- # print(json.dumps(result))
63
64
return result
65
0 commit comments