Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Fixed the test suite on PyPy | Alex Grönholm | 2022-09-22 | 1 | -1/+10 |
| | |||||
* | Readded psycopg2 and pymysql store fixtures to the test suite | Alex Grönholm | 2022-09-21 | 1 | -1/+11 |
| | |||||
* | Fixed missing schema with the psycopg2 store fixture | Alex Grönholm | 2022-09-21 | 1 | -1/+5 |
| | |||||
* | Merged the Worker class into AsyncScheduler | Alex Grönholm | 2022-09-21 | 1 | -10/+12 |
| | |||||
* | Major refactoring | Alex Grönholm | 2022-09-21 | 5 | -1561/+710 |
| | | | | | | | | - Made SyncScheduler a synchronous wrapper for AsyncScheduler - Removed workers as a user interface - Removed synchronous interfaces for data stores and event brokers and refactored existing implementations to use the async interface - Added the current_async_scheduler contextvar - Added job executors | ||||
* | Fixed schema parameter in SQLAlchemyJobStore not being used | Alex Grönholm | 2022-09-12 | 1 | -1/+1 |
| | | | | Fixes #664. | ||||
* | Fixed private module imports in tests | Alex Grönholm | 2022-09-07 | 2 | -2/+5 |
| | |||||
* | Changed the scheduler API to require an explicit start call | Alex Grönholm | 2022-09-04 | 1 | -4/+40 |
| | |||||
* | Improved the asyncpg event broker | Alex Grönholm | 2022-09-03 | 1 | -5/+3 |
| | | | | | | * It now recovers from a server disconnection * Replaced from_asyncpg_pool() with from_dsn() * Only copy the connection options from the async engine in from_async_sqla_engine() | ||||
* | Added async Redis event broker and made the sync one resistant to ↵ | Alex Grönholm | 2022-09-03 | 1 | -2/+18 |
| | | | | connectivity failures | ||||
* | Fixed JSON/CBOR serialization of JobReleased events | Alex Grönholm | 2022-09-03 | 1 | -0/+15 |
| | |||||
* | Fixed flaky test | Alex Grönholm | 2022-08-17 | 1 | -1/+1 |
| | |||||
* | Formatted all code to fit within Black's 88 column limit | Alex Grönholm | 2022-08-17 | 5 | -25/+29 |
| | |||||
* | Added exception information to the JobReleased class | Alex Grönholm | 2022-08-14 | 1 | -0/+18 |
| | |||||
* | Added job expiration times | Alex Grönholm | 2022-08-13 | 2 | -37/+99 |
| | | | | | Scheduled jobs no longer retain their results. All job outcomes are now logged by the workers. Workers, rather than data stores, are now responsible for emitting the JobReleased event. | ||||
* | Added get_schedules() methods to the scheduler classes | Alex Grönholm | 2022-08-09 | 1 | -0/+34 |
| | |||||
* | Renamed the job_info contextvar into current_job | Alex Grönholm | 2022-08-09 | 1 | -3/+3 |
| | |||||
* | Made the apscheduler.events module private and re-exported its code | Alex Grönholm | 2022-07-31 | 5 | -22/+24 |
| | |||||
* | Made the apscheduler.context module private and re-exported its code | Alex Grönholm | 2022-07-30 | 1 | -1/+3 |
| | |||||
* | Made the apscheduler.structures module private and re-exported its code | Alex Grönholm | 2022-07-30 | 3 | -14/+12 |
| | |||||
* | Made the apscheduler.enums and apscheduler.exceptions modules private and ↵ | Alex Grönholm | 2022-07-30 | 5 | -7/+5 |
| | | | | re-exported their code | ||||
* | Changed get_schedule() to raise ScheduleLookupError when the target schedule ↵ | Alex Grönholm | 2022-07-30 | 1 | -2/+22 |
| | | | | isn't found | ||||
* | Fixed JSON serialization of frozensets and UUIDs | Alex Grönholm | 2022-07-27 | 1 | -1/+1 |
| | |||||
* | Implemented (un)marshalling for events | Alex Grönholm | 2022-07-27 | 1 | -0/+28 |
| | | | | This fixes JSON (de)serialization of certain events. | ||||
* | Tested SQLAlchemy data store against MySQL, and fixed missing "await" | Alex Grönholm | 2022-07-27 | 1 | -0/+20 |
| | |||||
* | Improved the scheduler lifecycle management | Alex Grönholm | 2022-07-27 | 1 | -0/+22 |
| | | | | Both sync and async schedulers now have consistently working stop() and wait_until_stopped() methods. | ||||
* | Fixed get_task() failing in SQLAlchemy data stores | Alex Grönholm | 2022-07-27 | 1 | -0/+19 |
| | |||||
* | Fixed asyncpg event broker not having a "serializer" attribute | Alex Grönholm | 2022-07-24 | 1 | -2/+1 |
| | |||||
* | Added another missing pytest.fixture decorator | Alex Grönholm | 2022-07-24 | 1 | -0/+1 |
| | |||||
* | Added missing pytest.fixture decorator | Alex Grönholm | 2022-07-24 | 1 | -0/+1 |
| | |||||
* | Fixed CancelScope errors when the startup or shutdown of ↵ | Alex Grönholm | 2022-07-24 | 2 | -11/+50 |
| | | | | AsyncDataStoreAdapter is cancelled | ||||
* | Added support for starting the sync scheduler (and worker) without the ↵ | Alex Grönholm | 2022-07-19 | 4 | -419/+820 |
| | | | | context manager | ||||
* | Fixed test failures | Alex Grönholm | 2022-04-26 | 1 | -1/+1 |
| | |||||
* | Fixed SQLAlchemy stores failing on multiple schedule release | Alex Grönholm | 2022-04-20 | 1 | -34/+18 |
| | | | | | This only happened where RETURNING was supported for updates (PostgreSQL). Fixes #621. | ||||
* | Switched to Black for code formatting | Alex Grönholm | 2022-04-20 | 10 | -476/+851 |
| | |||||
* | Fixed pre-commit errors | Alex Grönholm | 2022-04-18 | 1 | -1/+3 |
| | |||||
* | Fixed ValueError in memory store | Alex Grönholm | 2022-04-18 | 1 | -0/+17 |
| | | | | | | This occurred when two schedules were released simultaneously, with one being finished and one still running. Fixes #616. | ||||
* | Fixed mypy errors in tests | Alex Grönholm | 2022-02-15 | 3 | -24/+28 |
| | |||||
* | Upgraded syntax and switched linting over to pre-commit.ci | Alex Grönholm | 2022-01-02 | 6 | -10/+18 |
| | | | | Linting checks are now run by pre-commit.ci instead of GitHub Actions. | ||||
* | Implemented context-local variables for running jobs | Alex Grönholm | 2021-09-21 | 1 | -0/+54 |
| | |||||
* | Implemented schedule-level jitter | Alex Grönholm | 2021-09-21 | 2 | -14/+106 |
| | | | | 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 schedules | Alex Grönholm | 2021-09-13 | 2 | -14/+89 |
| | |||||
* | Switched tests to Python 3.10 style annotations | Alex Grönholm | 2021-09-13 | 8 | -18/+27 |
| | |||||
* | Implemented one-shot event subscriptions | Alex Grönholm | 2021-09-13 | 1 | -104/+53 |
| | | | | Such subscriptions are delivered the first matching event and then unsubscribed automatically. | ||||
* | Improved the event subscription system | Alex Grönholm | 2021-09-12 | 4 | -12/+12 |
| | | | | The subscribe() method now returns a subscription which has the unsubscribe() method in itself. | ||||
* | Reduced the number of job completion events | Alex Grönholm | 2021-09-12 | 2 | -18/+16 |
| | |||||
* | Applied the external_service mark to redis + mqtt tests too | Alex Grönholm | 2021-09-11 | 1 | -3/+6 |
| | |||||
* | Applied pytest-lazy-fixture to data stores too | Alex Grönholm | 2021-09-11 | 2 | -222/+218 |
| | |||||
* | Implemented a pluggable event broker system | Alex Grönholm | 2021-09-11 | 4 | -138/+281 |
| | |||||
* | Rearranged the data stores | Alex Grönholm | 2021-09-08 | 2 | -9/+9 |
| |