launchflow / buildflow

BuildFlow, is an open source framework for building large scale systems using Python. All you need to do is describe where your input is coming from and where your output should be written, and BuildFlow handles the rest. No configuration outside of the code is required.
https://docs.launchflow.com/buildflow
Apache License 2.0
190 stars 7 forks source link

expose ack id in pub/sub message #325

Closed boetro closed 7 months ago

boetro commented 7 months ago

This will allow users to extend the ack deadline if needed

codecov[bot] commented 7 months ago

Codecov Report

Attention: 1476 lines in your changes are missing coverage. Please review.

Comparison is base (0b616bb) 78.72% compared to head (ccb3cf1) 74.53%. Report is 86 commits behind head on main.

Files Patch % Lines
...ntime/actors/consumer_pattern/pull_process_push.py 23.29% 135 Missing :warning:
buildflow/core/app/flow.py 72.41% 128 Missing :warning:
buildflow/core/app/runtime/fastapi.py 18.01% 91 Missing :warning:
buildflow/core/app/runtime/actors/runtime.py 18.09% 86 Missing :warning:
...ake/background_tasks/table_load_background_task.py 32.00% 85 Missing :warning:
buildflow/core/app/infra/actors/infra.py 12.08% 80 Missing :warning:
...tors/collector_pattern/receive_process_push_ack.py 34.06% 60 Missing :warning:
...p/runtime/actors/consumer_pattern/consumer_pool.py 26.58% 58 Missing :warning:
...actors/endpoint_pattern/receive_process_respond.py 39.74% 47 Missing :warning:
buildflow/core/processor/utils.py 23.52% 39 Missing :warning:
... and 77 more
Additional details and impacted files ```diff @@ Coverage Diff @@ ## main #325 +/- ## ========================================== - Coverage 78.72% 74.53% -4.19% ========================================== Files 103 168 +65 Lines 3648 7537 +3889 ========================================== + Hits 2872 5618 +2746 - Misses 776 1919 +1143 ```

:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.