TerminateAllPodLogs() does not work as expected

[whynowy]

Describe the bug

Investigate if defer w.StreamVertexPodlogs("sink", "udsink").TerminateAllPodLogs() works as expected - should see logs like "Terminating log streaming for POD xxxx before pipeline termination.

To Reproduce
Steps to reproduce the behavior:

1. ....
2. ....
3. ....

Expected behavior
A clear and concise description of what you expected to happen.

Screenshots
If applicable, add screenshots to help explain your problem.

Environment (please complete the following information):

• Kubernetes: [e.g. v1.18.6]
• Numaflow: [e.g. v0.5.1]

Additional context
Add any other context about the problem here.

---

Message from the maintainers:

Impacted by this bug? Give it a 👍. We often sort issues this way to know what to prioritize.

For quick help and support, join our slack channel.