Hi everyone,
Here is an example of how to divide up processing of integrations that have long-running tasks, for example web service calls that take longer than 2-3 minutes that cause a timeout in flow processing. One solution is to use Pub/Sub as an event to resume processing after processing is completed from some longer-running task.
Here is a YouTube video of the solution in action:
The example is very easy to deploy into your own Google Cloud project, see source code here: https://github.com/api-integration-samples/long-processing-sample.
Feel free to reach out here with any questions!
Hey! Thank you for sharing this example, it's a great resource for the community, and we appreciate your contribution. 🙂