Coverage for src/couchers/jobs/enqueue.py: 100%

1""" 

2Background jobs 

3""" 

4 

5import logging 

6 

7from couchers.models import BackgroundJob 

8 

9logger = logging.getLogger(__name__) 

10 

11 

12def queue_job(session, job_type: str, payload, max_tries=None, priority=None): 

13 session.add( 

14 BackgroundJob( 

15 job_type=job_type, 

16 payload=payload.SerializeToString(), 

17 max_tries=max_tries, 

18 priority=priority, 

19 ) 

20 )