File size: 476 Bytes
1c5aca1
 
f1e0138
 
 
 
 
 
 
 
01e8928
1c5aca1
 
 
 
01e8928
1c5aca1
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
"""Worker utilities for running STream3R jobs via RQ."""

from rq.queue import Queue

from .config import WorkerSettings

_settings = WorkerSettings.from_env()
if _settings.default_job_timeout and _settings.default_job_timeout > 0:
    Queue.DEFAULT_TIMEOUT = _settings.default_job_timeout

from .tasks import keyframe_selection_job, model_build_job, pose_pointmap_job  # noqa: E402

__all__ = [
    "pose_pointmap_job",
    "model_build_job",
    "keyframe_selection_job",
]