Skip to content

Tags: AmpelProject/Ampel-core

Tags

v0.10.6a11

Toggle v0.10.6a11's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Pause buffer fill on push (#301)

* Prevent current buffer from overfilling while writes complete

* Send bulk updates in parallel

* Move thread pool out of context

v0.10.6a10

Toggle v0.10.6a10's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Simplify DBUpdatesBuffer threading (#300)

* MongoIngester: expose buffer parameters

* Actually parallelize bulk write

* Delegate push to thread

* Promote push interval to float

v0.10.6a8

Toggle v0.10.6a8's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
AmpelLogger: support stack_info, stacklevel kwargs (#299)

Useful for logging in context managers

v0.10.6a7

Toggle v0.10.6a7's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Encapsulate setup/teardown in context managers (#297)

There are lots of places where some setup needs to happen before a
code block, and some action needs to happen afterwards:

- DBUpdatesBuffer: start/stop pusher thread, flush buffered updates
- AmpelLogger: flush buffered records
- AbsWorker and co: set current run id, clear cached unit instances
- AbsConsumer: subscribe/unsubscribe from queue
- AbsProducer: flush buffered messages

While all of these can be handled by try/finally blocks, this puts
onus on the user to clean up afterwards.  Use context managers to
encapsulate these steps in the objects themselves.

v0.10.6a6

Toggle v0.10.6a6's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Pass extra args to IngestionWorker (#296)

v0.10.6a5

Toggle v0.10.6a5's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Add IngestionWorker, factor MongoStockUpdater into AbsIngester (#295)

* Add IngestionWorker, a worker that ingests

* Factor MongoStockUpdater interface into AbsIngester

v0.10.6a4

Toggle v0.10.6a4's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Add a null producer for testing (#294)

v0.10.6a3

Toggle v0.10.6a3's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Skip already run T2 docs (#293)

v0.10.6a2

Toggle v0.10.6a2's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Move grouping context out of ChainedIngestionHandler (#292)

* Move grouping context out of ChainedIngestionHandler

* Bump version to 0.10.6a2

* Move ack inside context

v0.10.6a1

Toggle v0.10.6a1's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Batch acknowledgments in AbsConsumer (#291)

* Skip datapoint retention if not implemented

* Acknowledge in chunks

* Verify ack batching

* Bump version to 0.10.6a1