Skip to content

Conversation

@vigith
Copy link
Member

@vigith vigith commented Nov 12, 2025

Manifests for #283

Source

➜  source git:(source) ✗ kl simple-source-in-0-h4awv | head
Starting NumaflowCore: event_loop=Py(0xffff8e69e650)
INFO:__main__:Read request: num_records=5, timeout_ms=1000
INFO:__main__:Generated message: 0
INFO:__main__:Generated message: 1
INFO:__main__:Generated message: 2
INFO:__main__:Generated message: 3
INFO:__main__:Generated message: 4
INFO:__main__:Acknowledging 5 offsets
INFO:__main__:Read request: num_records=5, timeout_ms=1000
INFO:__main__:Generated message: 5
INFO:__main__:Generated message: 6
INFO:__main__:Generated message: 7
INFO:__main__:Generated message: 8
INFO:__main__:Generated message: 9
INFO:__main__:Acknowledging 5 offsets
INFO:__main__:Read request: num_records=5, timeout_ms=1000

Sink

{"timestamp":"2025-11-11T19:25:08.092765Z","level":"INFO","message":"Payload - message-5 Keys - key1 EventTime - 1762889105707 Headers -  ID - out-6-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-11T19:25:08.092797Z","level":"INFO","message":"Payload - message-6 Keys - key1 EventTime - 1762889105811 Headers -  ID - out-7-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-11T19:25:08.092801Z","level":"INFO","message":"Payload - message-7 Keys - key1 EventTime - 1762889105912 Headers -  ID - out-8-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-11T19:25:08.092804Z","level":"INFO","message":"Payload - message-8 Keys - key1 EventTime - 1762889106017 Headers -  ID - out-9-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-11T19:25:08.092806Z","level":"INFO","message":"Payload - message-9 Keys - key1 EventTime - 1762889106126 Headers -  ID - out-10-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-11T19:25:08.092809Z","level":"INFO","message":"Payload - message-10 Keys - key1 EventTime - 1762889106240 Headers -  ID - out-11-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-11T19:25:08.092811Z","level":"INFO","message":"Payload - message-11 Keys - key1 EventTime - 1762889106345 Headers -  ID - out-12-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-11T19:25:08.092813Z","level":"INFO","message":"Payload - message-12 Keys - key1 EventTime - 1762889106447 Headers -  ID - out-13-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-11T19:25:08.092815Z","level":"INFO","message":"Payload - message-13 Keys - key1 EventTime - 1762889106549 Headers -  ID - out-14-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-11T19:25:08.092818Z","level":"INFO","message":"Payload - message-14 Keys - key1 EventTime - 1762889106651 Headers -  ID - out-15-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-11T19:25:09.075889Z","level":"INFO","message":"Processed messages per second","processed":"10","target":"numaflow_core::tracker"}

Signed-off-by: Vigith Maurice <vigith@gmail.com>
@vigith vigith requested review from ab93 and whynowy as code owners November 12, 2025 18:04
@vigith vigith requested a review from BulkBeing November 12, 2025 18:04
@codecov
Copy link

codecov bot commented Nov 12, 2025

Codecov Report

✅ All modified and coverable lines are covered by tests.
✅ Project coverage is 93.88%. Comparing base (c9dccff) to head (7968f1f).
⚠️ Report is 1 commits behind head on main.

Additional details and impacted files
@@            Coverage Diff             @@
##             main     #285      +/-   ##
==========================================
- Coverage   93.91%   93.88%   -0.04%     
==========================================
  Files          66       66              
  Lines        3009     3009              
  Branches      155      155              
==========================================
- Hits         2826     2825       -1     
- Misses        133      134       +1     
  Partials       50       50              

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

Signed-off-by: Vigith Maurice <vigith@gmail.com>
@vigith vigith merged commit b0c7e7b into main Nov 13, 2025
13 checks passed
@vigith vigith deleted the source-manifests branch November 13, 2025 01:07
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants