Hi, I'm working on a python streaming pipeline and I'm trying to simulate different execution times to test business logic depending on current time + records data. When I freeze the time using freezegun <https://github.com/spulec/freezegun> the TestPipeline never finishes. I'm guessing it is waiting for some time to pass but as the time is frozen it never changes. Do you know any workaround or a different approach to test this?
Best
