Numaflow should call Source::Pending only for replica-id 0

[vigith]

Summary

We need to see whether every pod should make a pending call to the upstream source. We only read from pod-0, this will remove lot of pressure on the external source. I am worried whether we might in log run bring down the external source if the pending call is expensive. Also, for any pods other than replica-id 0, this information is meaningless.

Use Cases

• Every deployment

Tasks

Preview Give feedback

1. only replica-id 0 pod in MonoVertex and Pipeline makes pending call
2. move pending logs to debug! for pod-0 and omit for others