diff options
| author | Christian Cleberg <[email protected]> | 2026-05-06 23:19:54 -0500 |
|---|---|---|
| committer | Christian Cleberg <[email protected]> | 2026-05-06 23:19:54 -0500 |
| commit | 6289a28296bd0863d373bb47c1c85038f4bc6a2b (patch) | |
| tree | dee6f38ddf69ef361ceaccc855ac8b70cbe302a2 /src/srht_contrib/scripts/enqueue_actors.py | |
| parent | 79182c129011a65bec9006d295dbe382b0d81f97 (diff) | |
| download | hutch-stats-6289a28296bd0863d373bb47c1c85038f4bc6a2b.tar.gz hutch-stats-6289a28296bd0863d373bb47c1c85038f4bc6a2b.tar.bz2 hutch-stats-6289a28296bd0863d373bb47c1c85038f4bc6a2b.zip | |
feat: improve scheduled indexing throughput and capped backoff
Diffstat (limited to 'src/srht_contrib/scripts/enqueue_actors.py')
| -rw-r--r-- | src/srht_contrib/scripts/enqueue_actors.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/srht_contrib/scripts/enqueue_actors.py b/src/srht_contrib/scripts/enqueue_actors.py index 03f1f9b..bd838cb 100644 --- a/src/srht_contrib/scripts/enqueue_actors.py +++ b/src/srht_contrib/scripts/enqueue_actors.py @@ -40,7 +40,7 @@ def _iter_usernames(path: Path) -> list[str]: return usernames -def enqueue_actors(username_file: Path, *, stagger_seconds: int = 300, start_at: datetime | None = None) -> int: +def enqueue_actors(username_file: Path, *, stagger_seconds: int = 60, start_at: datetime | None = None) -> int: settings = Settings() session_factory = make_session_factory(settings) usernames = _iter_usernames(username_file) @@ -95,7 +95,7 @@ def main() -> None: parser.add_argument( "--stagger-seconds", type=int, - default=300, + default=60, help="Seconds to space out each actor's first eligible poll time.", ) args = parser.parse_args() |