Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

add support to delay a job and enqueue it N seconds later #211

Open
wants to merge 51 commits into
base: master
Choose a base branch
from
Open

add support to delay a job and enqueue it N seconds later #211

wants to merge 51 commits into from

Conversation

orlandobcrra
Copy link
Contributor

@orlandobcrra orlandobcrra commented Mar 24, 2019 •
edited
Loading

add support to delay a job and enqueue it N seconds later.
those jobs are going to have the delayed status.
e.g: delay a job 1 hour.

queue_job(main_task_path, params, delay=3600)

@orlandobcrra
Copy link
Contributor Author

Hi @maelorn @sylvinus, please if you could take a look at this PR when you get a chance. thanks.

@maelorn
Copy link
Contributor

maelorn commented Apr 21, 2019

Hello,

Sorry for the delay. Can you tell us a bit more about the specific use case where you would need this ? Maybe it is something we can already handle right now. Thanks.

@orlandobcrra
Copy link
Contributor Author

Hello,

For example if we need to send an email 1 hour later from a given action:
Endpoint A is called on our API and we need to send an email with some info we got from this process but not right away, we need to send the email N minutes later.

@maelorn
Copy link
Contributor

maelorn commented Apr 22, 2019

Allright, we don't indeed have anything in that regard. It seems fine to me. Could you just add a small test validating the wanted behaviour please ?

kevteg and others added 25 commits April 22, 2019 18:05
@kevteg
getting latest job with certain status
1e75c7a
@kevteg
Moving method to job methods
211ac8f
@kevteg
updating name and version
4e8696d
@kevteg
0.9.12 version
b7eb6c9
@kevteg
using query instead of status and path
556c40e
@icardenas
042419IC Add support to delete success or cancel jobs that are alread…
5074b4c 
…y expired
@icardenas
042419IC draft test for check test_delete_expired_jobs
cd1a56d
@icardenas
Update Version 0.9.13
91001d9
@icardenas
Update Version 0.9.14
6c17383
@icardenas
Delete TODO word
1377520
@icardenas
Merge pull request #2 from apploitech/042419IC_add_remove_expires_jobs
78a1e87 
042419IC Remove expired jobs
@icardenas
042419IC verify version of python to iterate dictionary
c038608
@icardenas
042419IC Update version
7beb029
@icardenas
Update utils.py
5b36b23
@icardenas
update version
42957f3
@icardenas
042419IC Fix and update version
7d51f8f
@icardenas
Merge pull request #3 from apploitech/042419IC_fix_dictionary_iterati…
87fe03b 
…on_version

Verify python version to iterate dictionary
@icardenas
Add status maxretries in endpoint '/api/datatables/taskexceptions'
4eca72b
@icardenas
Add status maxretries in endpoint '/api/datatables/taskexceptions'
721ba39
@icardenas
Add the status field in the search for exceptions
e9fe738
@icardenas
042619IC Update Version
e76e1a0
@icardenas
minor fix bundle
fc95b0a
@icardenas
Merge pull request #4 from apploitech/042619IC_add_maxretries_in_task…
5d1bffc 
…exceptions

042619IC add maxretries in taskexceptions
@Darking360
Adding get latest jobs based on a query
74d913f
@Darking360
Adding sort
45bc6c7
Darking360 and others added 25 commits May 6, 2019 11:41
@Darking360
Increasing MRQ lib version
6c85adf
@Darking360
Merge pull request #5 from apploitech/050319MR_add_latest_jobs_query
5ca8555 
Add get latest jobs query
@ghabrielv
Add Redis SSL support
63fa50a
@ghabrielv
Increasing MRQ lib version
634c217
@ghabrielv
Fix pypy portable url
6fdfd29
@ghabrielv
Update dockerfile
5076764
@ghabrielv
Update dockerfile
ff2a3a4
@ghabrielv
Update library psutil
ddda42a
@ghabrielv
Update requirements and dockerfile
adc365e
@ghabrielv
Specific log description content type
964a14b
@ghabrielv
Version 0.9.23 and redis password
dd8cb5f
@ghabrielv
Merge pull request #6 from apploitech/redis-ssl
78485ac 
Add Redis SSL support
@ghabrielv
Sentry cleanup (#7)
aa98be8 
* Sentry cleanup

* Improve exceptions message

* Improve AbortInterrupt, MaxRetriesInterrupt and MaxConcurrencyInterrupt
@ghabrielv
Upgrade psutil to 5.8.0 (#8)
c902409 
* Update psutil to 5.8.0

* MRQ Custom 0.9.28
@orlandobcrra
A3S-1593 - if "retry_current_job" is call outside of an MRQ context, …
e6d05e9 
…then raise exception. (#9)

Thus, the actual worker performing the execution of this task can use its own error handling. E.g. Lambda function.
@ghabrielv
A3S-2518 Remove print line and document the process of generating a n…
3389b17 
…ew version of MRQ (#12)

* Remove print line
* Update readme.md
* Up version
@orlandobcrra
Update processes.py
bd6ba3d
A3S-2202: version upgrade
37ee776
@ghabrielv
A3S-2753: Updated redis to 4.5.5 version
b8ecdf4
@ghabrielv
A3S-2749: Settled MRQ version to 0.9.32
8b19f1e
@Sarahoyos
Merge pull request #13 from apploitech/A3S-2753
4143816 
A3S-2753: Updated redis to 4.5.5 version and new MRQ-custom version
@ghabrielv
A3S-2753 Fixed redis SSL connection (#14)
adf6ec9 
* A3S-2753: Fixed redis connection
@ghabrielv
A3S-2753: Fixed redis SSL connection (#15)
c1d55de 
* A3S-2753: Fixed redis connection
* A3S-2753: Fixed ssl_cert_reqs attribute
* A3S-2753: Improved fix ssl_cert_reqs attribute
* A3S-2793: Updated mrq-custom to version 0.9.34.1
A3S-843: update pymongo to support python 3.11
4f68e94
@jefarr-apploi
Merge pull request #16 from apploitech/a3s-843_update_pymongo
e630216 
A3s 843 update pymongo to support python 3.11
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.

None yet
8 participants
@orlandobcrra @maelorn @kevteg @icardenas @Darking360 @ghabrielv @Sarahoyos @jefarr-apploi