+ action = new
+ if action.status == 'completed':
+ await action.model.disconnect()
+ action.model.loop.stop()
+
+
+async def run():
+ model = Model()
+ await model.connect_current()
+ await model.reset(force=True)
+ model.add_observer(MyModelObserver())