Sreekanth
> Please consider adding it to the builtin-source-e2e suite instead of creating a new one. Otherwise, you need to add it to the .github/workflows/ci.yaml I've added it to `ci.yaml` instead...
Snyk reports vulnerabilities with 2 indirect dependencies that got added when I added `http://github.com/apache/pulsar-client-go` (latest version). - http://github.com/hamba/avro - http://github.com/AthenZ/athenz (issue is with its transitive dependencies) I tried upgrading these...
The test is present in the CI pipeline (`pulsar-e2e`).
https://github.com/numaproj/numaflow/pull/2581
I think we should rely on message passing to shutdown tasks. Another possible option is to return join handles in a wrapper struct and abort tasks within the `Drop` implementation...