I'm designing a Workflow with some HITL steps. I have successfully accomplished to break the streaming of events and capture the human input event.
At this point, most examples connect via input() or a websocket and then resume operations. But my use case needs to be asynhronous.
I need to be able to checkpoint the workflow, save it somewhere (e.g. a database) and pause execution.
Later, when i receive the response from the human, i want to load the checkpoint, set the new event and continue.
So far, i'm able to stop at the desired event, save the checkpoint and load it again.
THE PROBLEM:
Breaking the streaming loop to capture the event prevents the Workflow to mark such step as completed, causing the Checkpointer to not checkpoint the progress of the step that emitted the InputRequiredEvent.
Is it possible to accomplish this? Can i somehow force the checkpointer or mark the step as done?
