schedula

import schedula as sh # 1. Define a Dispatcher, which is the main model for your dataflow dsp = sh.Dispatcher(name='my_simple_workflow') # 2. Define functions and add them to the Dispatcher using the decorator @sh.add_function(dsp, outputs=['y']) def add_one(x): print(f"Executing add_one with x={x}") return x + 1 @sh.add_function(dsp, outputs=['z']) def multiply_by_two(y): print(f"Executing multiply_by_two with y={y}") return y * 2 # 3. Dispatch the workflow with initial inputs and desired outputs initial_inputs = {'x': 5} desired_outputs = ['z'] try: results = dsp.dispatch(inputs=initial_inputs, outputs=desired_outputs) print(f"\nFinal result for 'z': {results['z']}") except Exception as e: print(f"An error occurred during dispatch: {e}")