Commit Graph

290 Commits

Author SHA1 Message Date
Eneko Lakasta
340e55ea46 reduce error info 2018-06-06 15:23:53 +02:00
Eneko Lakasta
62df0a387a remove functionality from parseMetadataToDatabase. DB user and pass not longer needed 2018-06-05 17:58:55 +02:00
Eneko Lakasta
4993f8a956 use job configuration instead of user metadata service in test 2018-06-05 17:56:29 +02:00
Eneko Lakasta
eab3d289b6 refactor authenticated to authorizationLevel 2018-06-05 13:21:56 +02:00
Eneko Lakasta
46e3a87f41 add some auth TODOs 2018-05-30 18:15:35 +02:00
Eneko Lakasta
71de7248ba get DB configuration from job instead from metadata in Job Canceller (again) 2018-05-30 17:38:06 +02:00
Eneko Lakasta
cf8bf6e5e6 get DB configuration from job instead from metadata in Job Canceller 2018-05-30 17:36:55 +02:00
Eneko Lakasta
681b60c27d return error if batch job has no proper DB configuration 2018-05-25 17:25:38 +02:00
Daniel García Aubert
f01bfbbfd6 Fix property names to not expose user's credential info 2018-02-15 13:12:40 +01:00
Daniel García Aubert
e2b8fa9e22 Retrieve database credentials from jobs stored in redis 2018-02-15 12:31:08 +01:00
Daniel García Aubert
b81df11a56 Pass user's database credentiasl to query runner 2018-02-15 12:26:36 +01:00
Daniel García Aubert
7a3ad2b5e0 Fallback: if the jod doesn't have databse credentials then get them from users' metadata 2018-02-15 12:25:55 +01:00
Daniel García Aubert
77b33032e3 Do not expose sensible info about users (database credentials) 2018-02-15 12:24:26 +01:00
Simon Martín
617b83463d jshint happy 2018-02-12 11:15:00 +01:00
Simon Martín
c351360085 ensuring job_id on jobBackend.create and updating test 2018-02-12 10:39:58 +01:00
Raul Ochoa
3e536b822e Remove unnecessary destroyOnError option 2017-08-08 18:21:10 +02:00
Daniel García Aubert
7d24ce671b Update queue index while enqueueing jobs to the top of queue 2017-04-05 11:43:29 +02:00
Daniel García Aubert
c1dff1e395 Improve naming 2017-04-04 10:34:07 +02:00
Daniel García Aubert
36d5dc1719 Queue seeker refactor:
- Extract from job subcriber everything related to queue dicovering
 - Job Queue is responsible of queue dicovering and exposes functions to scan user queues.
 - Batch creates an interval to consume queues
 - Now Batch.start() does:
  * Finds existing queues from metadata, adding to queue index the ones that are not indexed yet
  * Binds callback to process jobs for every queue found.
  * Inits queue consumer interval
  * Subscribes to PUB/SUB channel
2017-04-03 19:26:21 +02:00
Daniel García Aubert
24ff1cf808 Discover and add to index queues of users with jobs on batch service startup 2017-04-03 12:34:30 +02:00
Daniel García Aubert
8f35e1d1af Fix typo 2017-04-03 11:38:20 +02:00
Daniel García Aubert
dd7cb73337 Remove unused dependency 2017-03-31 14:34:24 +02:00
Daniel García Aubert
8012fe26aa Avoid scan behaviour to discover active queues of user's jobs, now keeps an index to know which queues are available 2017-03-31 14:30:33 +02:00
Daniel García Aubert
6592435e87 Use COUNT option for scan command 2017-03-29 20:40:40 +02:00
Daniel García Aubert
09d5a14ade Check data from redis scan is an array 2017-03-29 20:04:19 +02:00
Daniel García Aubert
56429ffebf Use traditional for loop instead of .forEach() 2017-03-29 19:54:08 +02:00
Daniel García Aubert
2edfd1fad5 Compare interger instead of strings 2017-03-29 19:51:19 +02:00
Daniel García Aubert
34b352a0a6 Use max number of attempts to scan user queues 2017-03-29 19:38:36 +02:00
Raul Ochoa
9ae62014bd Include query status in log entries 2016-11-30 16:07:14 +01:00
Daniel García Aubert
4a2b7258be Do not return error if job could not added to work-in-progress list 2016-11-07 12:04:47 +01:00
Daniel García Aubert
78f5706726 Avoid to use scan command to search work in progress queues 2016-11-03 14:22:43 +01:00
Daniel García Aubert
cfeabf94c7 Fix jshint typo 2016-11-02 11:33:26 +01:00
Daniel García Aubert
92b01f1163 Hide add/clear job from work in progress list 2016-10-28 17:45:13 +02:00
Daniel García Aubert
e007b1c22a Fix jshint typo 2016-10-28 17:09:31 +02:00
Daniel García Aubert
aa1527b371 Use clear work-in-progress after finishing jobs 2016-10-28 15:58:41 +02:00
Daniel García Aubert
eaa3315982 Add clear work in progress job to service 2016-10-28 15:19:49 +02:00
Daniel García Aubert
ea06581ddb Add clear work in progress job 2016-10-28 15:18:57 +02:00
Daniel García Aubert
64d0dc93bf Removed unnecessary debug 2016-10-28 15:06:07 +02:00
Daniel García Aubert
af75bbda50 Rename 2016-10-28 12:50:33 +02:00
Daniel García Aubert
c35b21407a Call list of work in progress job 2016-10-28 12:49:59 +02:00
Daniel García Aubert
f0de347b56 Rename 2016-10-28 12:30:33 +02:00
Daniel García Aubert
7b48e43d92 Rename 2016-10-28 12:29:28 +02:00
Daniel García Aubert
224a4c933a Rename 2016-10-28 12:26:24 +02:00
Daniel García Aubert
1f657a4f94 Ensure test is isolated 2016-10-28 12:24:23 +02:00
Daniel García Aubert
97836e62b9 Add debug message 2016-10-27 20:45:47 +02:00
Daniel García Aubert
72419072ea Improve var definitions 2016-10-27 20:43:42 +02:00
Daniel García Aubert
0085b8ee3d List users with work in progress jobs 2016-10-27 20:42:49 +02:00
Daniel García Aubert
f65208ba0d Add listWorkInProgressJobByUser function 2016-10-27 18:43:28 +02:00
Daniel García Aubert
5b8108d4a8 Use job service to add jobs to work-in-progress list 2016-10-27 18:00:56 +02:00
Daniel García Aubert
c1f2f9377d Change signature 2016-10-27 17:46:43 +02:00