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

update sources to be able to ack individual messages instead of the entire batch #301

Closed boetro closed 8 months ago

codecov[bot] commented 8 months ago

Codecov Report

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

Comparison is base (cb7001c) 77.64% compared to head (f7e33db) 77.58%. Report is 1 commits behind head on main.

Additional details and impacted files ```diff @@ Coverage Diff @@ ## main #301 +/- ## ========================================== - Coverage 77.64% 77.58% -0.07% ========================================== Files 160 161 +1 Lines 7060 7103 +43 ========================================== + Hits 5482 5511 +29 - Misses 1578 1592 +14 ``` | [Files](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow) | Coverage Δ | | |---|---|---| | [...trategies/s3\_file\_change\_stream\_strategies\_test.py](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow#diff-YnVpbGRmbG93L2lvL2F3cy9zdHJhdGVnaWVzL3MzX2ZpbGVfY2hhbmdlX3N0cmVhbV9zdHJhdGVnaWVzX3Rlc3QucHk=) | `100.00% <100.00%> (ø)` | | | [buildflow/io/aws/strategies/sqs\_strategies.py](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow#diff-YnVpbGRmbG93L2lvL2F3cy9zdHJhdGVnaWVzL3Nxc19zdHJhdGVnaWVzLnB5) | `92.39% <100.00%> (-0.32%)` | :arrow_down: | | [buildflow/io/aws/strategies/sqs\_strategies\_test.py](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow#diff-YnVpbGRmbG93L2lvL2F3cy9zdHJhdGVnaWVzL3Nxc19zdHJhdGVnaWVzX3Rlc3QucHk=) | `100.00% <100.00%> (ø)` | | | [buildflow/io/local/pulse\_test.py](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow#diff-YnVpbGRmbG93L2lvL2xvY2FsL3B1bHNlX3Rlc3QucHk=) | `100.00% <100.00%> (ø)` | | | [.../local/strategies/file\_change\_stream\_strategies.py](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow#diff-YnVpbGRmbG93L2lvL2xvY2FsL3N0cmF0ZWdpZXMvZmlsZV9jaGFuZ2Vfc3RyZWFtX3N0cmF0ZWdpZXMucHk=) | `93.54% <100.00%> (+0.21%)` | :arrow_up: | | [...l/strategies/file\_change\_stream\_strategies\_test.py](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow#diff-YnVpbGRmbG93L2lvL2xvY2FsL3N0cmF0ZWdpZXMvZmlsZV9jaGFuZ2Vfc3RyZWFtX3N0cmF0ZWdpZXNfdGVzdC5weQ==) | `96.29% <100.00%> (ø)` | | | [buildflow/io/local/strategies/pulse\_strategies.py](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow#diff-YnVpbGRmbG93L2lvL2xvY2FsL3N0cmF0ZWdpZXMvcHVsc2Vfc3RyYXRlZ2llcy5weQ==) | `85.71% <100.00%> (+0.52%)` | :arrow_up: | | [buildflow/io/strategies/source.py](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow#diff-YnVpbGRmbG93L2lvL3N0cmF0ZWdpZXMvc291cmNlLnB5) | `95.00% <100.00%> (-0.24%)` | :arrow_down: | | [...aws/strategies/s3\_file\_change\_stream\_strategies.py](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow#diff-YnVpbGRmbG93L2lvL2F3cy9zdHJhdGVnaWVzL3MzX2ZpbGVfY2hhbmdlX3N0cmVhbV9zdHJhdGVnaWVzLnB5) | `91.42% <80.00%> (ø)` | | | [...cp/strategies/gcs\_file\_change\_stream\_strategies.py](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow#diff-YnVpbGRmbG93L2lvL2djcC9zdHJhdGVnaWVzL2djc19maWxlX2NoYW5nZV9zdHJlYW1fc3RyYXRlZ2llcy5weQ==) | `56.00% <40.00%> (ø)` | | | ... and [2 more](https://app.codecov.io/gh/launchflow/buildflow/pull/301?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow) | | ... and [4 files with indirect coverage changes](https://app.codecov.io/gh/launchflow/buildflow/pull/301/indirect-changes?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=launchflow)

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