We might be able to use Celery Chains to simplify the workflow implementation. Alternatively moving to Temporal is another option to consider.