Hi again all, I am implementing querying in our long-running workflow processes and have been having trouble.
I’m trying to pass an activity stub to our main workflow activity process, which fires a data pipeline. The activity stub would call an activity method for each log message that the pipeline makes. I’m confused because when I pass the activity stub into the method, the call stack blows.
I’ve been led to understand that periodic updates from a workflow activity could also be implemented as a heartbeat – though it’s difficult to find any information on what this would look like in practice. If I were to need the values from each heartbeat, where would I be able to retrieve those? Would they be yielded from the activity method call as if it were a generator?