diff --git a/taskflow/examples/build_a_car.py b/taskflow/examples/build_a_car.py index a3291817..cb952f39 100644 --- a/taskflow/examples/build_a_car.py +++ b/taskflow/examples/build_a_car.py @@ -167,7 +167,7 @@ engine = taskflow.engines.load(flow, store={'spec': spec.copy()}) # flow_watch function for flow state transitions, and registers the # same all (ANY) state transitions for task state transitions. engine.notifier.register(ANY, flow_watch) -engine.task_notifier.register(ANY, task_watch) +engine.atom_notifier.register(ANY, task_watch) eu.print_wrapped("Building a car") engine.run() @@ -180,7 +180,7 @@ spec['doors'] = 5 engine = taskflow.engines.load(flow, store={'spec': spec.copy()}) engine.notifier.register(ANY, flow_watch) -engine.task_notifier.register(ANY, task_watch) +engine.atom_notifier.register(ANY, task_watch) eu.print_wrapped("Building a wrong car that doesn't match specification") try: