summaryrefslogtreecommitdiff
path: root/src
Commit message (Collapse)AuthorAgeFilesLines
...
* Cleaned up JSON unmarshalling codeAlex Grönholm2022-07-271-2/+2
|
* Improved the scheduler lifecycle managementAlex Grönholm2022-07-272-48/+121
| | | | Both sync and async schedulers now have consistently working stop() and wait_until_stopped() methods.
* Fixed get_task() failing in SQLAlchemy data storesAlex Grönholm2022-07-272-6/+6
|
* Fixed asyncpg event broker not having a "serializer" attributeAlex Grönholm2022-07-241-4/+9
|
* Fixed CancelScope errors when the startup or shutdown of ↵Alex Grönholm2022-07-241-4/+11
| | | | AsyncDataStoreAdapter is cancelled
* Added support for starting the sync scheduler (and worker) without the ↵Alex Grönholm2022-07-1920-753/+827
| | | | context manager
* Fixed return type annotation of AsyncpgEventBroker.__aenter__()Alex Grönholm2022-07-191-1/+1
|
* Wait until the scheduler has stopped before returning from stop()Alex Grönholm2022-07-191-9/+12
|
* Added the start_in_background() and run_until_stopped() methods to SchedulerAlex Grönholm2022-07-191-54/+57
|
* fix: Remove duplicate log (#628)Gol2022-05-231-1/+0
| | | When AsyncWorker is stopped normally, after the "Worker stopped" log, there is also a "Worker crashed" log, which should be removed it.
* Fixed test failuresAlex Grönholm2022-04-261-2/+3
|
* Fixed SQLAlchemy stores failing on multiple schedule releaseAlex Grönholm2022-04-202-19/+6
| | | | | This only happened where RETURNING was supported for updates (PostgreSQL). Fixes #621.
* Don't share retry statesAlex Grönholm2022-04-203-76/+66
| | | | Fixes #618.
* Switched to Black for code formattingAlex Grönholm2022-04-2034-889/+1719
|
* Fixed wrong indentation in async schedulerAlex Grönholm2022-04-181-2/+2
| | | | The line that releases schedules after processing was indented wrong, releasing the schedules too early.
* Added missing raise statement to async scheduler crash handlerAlex Grönholm2022-04-181-0/+1
|
* Fixed ValueError in memory storeAlex Grönholm2022-04-181-1/+3
| | | | | | This occurred when two schedules were released simultaneously, with one being finished and one still running. Fixes #616.
* Fixed scheduler waking up unnecessarilyAlex Grönholm2022-02-152-21/+39
| | | | Added checks to make the scheduler only wake up if there is a new or updated schedule that would trigger sooner than the previously nearest known schedule
* Added py.typed to the package directoryAlex Grönholm2022-02-151-0/+0
|
* Reduced the number of mypy errorsAlex Grönholm2022-02-152-10/+14
|
* Upgraded syntax and switched linting over to pre-commit.ciAlex Grönholm2022-01-0228-165/+168
| | | | Linting checks are now run by pre-commit.ci instead of GitHub Actions.
* Fixed compatibility with pymongo 4Alex Grönholm2022-01-021-2/+8
|
* Upgraded redis dependencyAlex Grönholm2022-01-021-4/+2
|
* Upgraded attrs and its importsAlex Grönholm2022-01-0227-276/+283
| | | | We now import "attrs" instead of "attr".
* Used an augmented assignment statementAlex Grönholm2021-11-041-1/+1
| | | | Closes #571.
* Improved scheduler and worker crash handlingAlex Grönholm2021-10-024-21/+29
|
* Filled in some missing type annotationsAlex Grönholm2021-10-025-21/+20
|
* Added the ability to retry operations to all persistent data storesAlex Grönholm2021-09-264-627/+784
|
* Removed the notify_channel parameterAlex Grönholm2021-09-261-1/+0
| | | | It's not longer used directly in the SQLAlchemy stores.
* Lock schedules and jobs for update while acquiringAlex Grönholm2021-09-262-2/+4
|
* Improved scheduler logging and fixed wait time calculationAlex Grönholm2021-09-232-7/+28
|
* Fixed a couple of bugs in the SQLAlchemy data storesAlex Grönholm2021-09-232-5/+6
|
* Refactored scheduler and worker classes to use attrsAlex Grönholm2021-09-226-85/+101
|
* Implemented context-local variables for running jobsAlex Grönholm2021-09-216-8/+72
|
* Implemented schedule-level jitterAlex Grönholm2021-09-216-56/+161
| | | | Structures now keep enums, timedeltas and frozensets as-is. The MongoDB store was modified to use a custom type registry to handle this.
* Added scheduler methods for creating jobs directly w/o schedulesAlex Grönholm2021-09-1311-88/+262
|
* Removed debugging codeAlex Grönholm2021-09-131-1/+0
|
* Implemented one-shot event subscriptionsAlex Grönholm2021-09-136-22/+40
| | | | Such subscriptions are delivered the first matching event and then unsubscribed automatically.
* Guard subscriptions in the synchronous local event broker with a lockAlex Grönholm2021-09-121-4/+12
| | | | This allows the local event broker to safely iterate through the original list of subscriptions while publishing an event, instead of having to atomically make a shallow copy every time.
* Added context manager support to event subscriptionsAlex Grönholm2021-09-126-34/+40
|
* Improved the event subscription systemAlex Grönholm2021-09-1212-145/+107
| | | | The subscribe() method now returns a subscription which has the unsubscribe() method in itself.
* Refactored event brokers to use exit stacksAlex Grönholm2021-09-129-55/+62
|
* Reduced the number of job completion eventsAlex Grönholm2021-09-125-69/+26
|
* Implemented a pluggable event broker systemAlex Grönholm2021-09-1122-315/+681
|
* Deduplicated some SQLAlchemy store codeAlex Grönholm2021-09-082-145/+53
|
* Rearranged the data storesAlex Grönholm2021-09-0810-71/+50
|
* More type annotation updatesAlex Grönholm2021-09-0812-27/+29
|
* Converted more classes to use attrsAlex Grönholm2021-09-086-97/+86
|
* Serialize top level attributes into individual fields/columnsAlex Grönholm2021-09-089-211/+284
|
* Use the real UUID column type where supportedAlex Grönholm2021-09-062-28/+64
|
View Lorry Controller Status