where

case(False)

Result

str

json.dumps

S3Result

LocalResult

��QXQ >> to the beginning
�. >> to the end

with open()

task_B

task_A

task_B

task_A

prefect.engine.signals.SKIP(None)

task_B

task_B

task_C

task_X

if isinstance(input, prefect.signals.SKIP): raise prefect.signals.SKIP

data

'FunctionTask' object has no attribute 'data'

with Flow('data_transformation') as flow:
     response = myTask()
     response.data //error

flow.run()

State Message: {'_schema': 'Invalid data type: None'}

Invalid Project!

az acr login

prefect register

[2022-02-17 12:29:19+0000] INFO - prefect.wait_for_flow_run | Flow 'affable-piculet-flow-build│

-dataset': Entered state <Failed>: Unexpected error while running flow: KeyError('Task slug do_someting-1 is not found in the current Flow. This is usually caused by a mismatch between th│

e flow version stored in the Prefect backend and the flow that was loaded from storage.\n- Did│

 you change the flow without re-registering it?\n- Did you register the flow without updating │

it in your storage location (if applicable)?')                                                │

from flows.a import flow as flow_a   # flow's name is "flow-a"
from flows.b import flow as flow_b   # flow's name is "flow-b"

kwargs = {
"project_name": "foo",
"labels": ["test"]
}

flow_a.register(**kwargs)
flow_b.register(**kwargs)

with Flow("flow-of-flows", run_config=run_config, storage=storage, result=result) as flow:

   run_id_flow_a = create_flow_run(flow_name="flow-a", **kwargs)
   wait_for_flow_a = wait_for_flow_run(run_id_flow_a, raise_final_state=True)
   output_a = get_task_run_result(run_id_flow_a, task_slug="do_something-1")
   
   run_id_flow_b = create_flow_run(flow_name="flow-b", parameters={"input": output_a}, **kwargs)
   run_id_flow_b.set_upstream(wait_for_flow_a)

flow.register(**kwargs)

POST: <http://localhost:4200/api/flow_runs/>

PAYLOAD:
{
  "name": "my_scheduled_flow",
  "deployment_id": "0ff88fc8-a71c-4b71-b8dd-078d6a36fb39",
  "flow_id": "94374bea-70ae-4e49-8988-e9077daa280a",
  "flow_version": "1.0",
  "state": {
    "type": "SCHEDULED",
    "name": "my_scheduled_flow",
    "message": "a message",
    "state_details": {
        "scheduled_time": "2022-02-18T16:10:49.005Z"
    }
  }
}