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.

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

enum34 be gone #3181

Closed
wants to merge 43 commits into from
Closed
Changes from 1 commit
Commits
Show all changes
43 commits
Select commit Hold shift + click to select a range
bece355
Adds batched_params which is a dictionary of lists of batched paramet…
ejsundstr Dec 17, 2018
ccb86fb
missed the worker bit
ejsundstr Dec 18, 2018
a3ad7cb
update setup.py
ejsundstr Dec 18, 2018
8e82b80
backport of ParameterVisibilities
ejsundstr Dec 28, 2018
4bb3b55
Test fixes and version bump
ejsundstr Jan 7, 2019
0d874f6
Merge pull request #7 from Affirm/ejs/add_parameter_visibility
ejsundstr Jan 18, 2019
f3dec1a
Luigi email region for 2.7.5
gregsterin Oct 3, 2019
4d3289f
Bump luigi version
Oct 9, 2019
769d3ac
Luigi email region for 2.7.5
gregsterin Oct 3, 2019
f87db0e
Added new batched_params to the task
ejsundstr Jul 4, 2018
1fe5f10
Add and mod tests to test batched_params
ejsundstr Jul 4, 2018
a21a905
Add a superset/subset batch test
ejsundstr Jul 5, 2018
2e7c5a0
Bump setup.py version number
ejsundstr Jul 5, 2018
1a02545
Fixes for batched_params (default and non-list)
ejsundstr Jul 6, 2018
7ba5c9b
update tests for new batched_params
ejsundstr Jul 14, 2018
8d75ade
fix RangeX classes to support param-name from the base class
ejsundstr Jul 14, 2018
0bb32ca
add a test pairing MixinNaiveBulkComplete and ranges
ejsundstr Jul 14, 2018
0ff3638
added a reload for batch jobs as they are now dynamic
ejsundstr Jul 17, 2018
ffc7342
Handle config python2/3 compatibility
Mar 27, 2019
1ea3188
Version bump
Nov 8, 2019
4016e8e
patch in LuigiRunResult and LuigiStatusCode with additional field for…
alexyu0 Nov 18, 2019
0563c49
success should be 0
alexyu0 Nov 20, 2019
4f13ace
only return status code num to keep interface similar to returning bool
alexyu0 Jan 21, 2020
12ead7b
remove interpolation import thing
alexyu0 Jan 23, 2020
c85d5ec
Merge pull request #11 from Affirm/alexyu/2.7.5/patch-verbose-retcodes
alexyu0 Feb 4, 2020
8761f94
Merge branch '2.7.5-affirm' into gloliva/2.7.5/merge-versions
alexyu0 Feb 4, 2020
f769316
version bump from 1.1.0 to 1.2.0
alexyu0 Feb 4, 2020
7a35fcc
remove enum34 requirement version bump since was accident
alexyu0 Feb 5, 2020
b0d9646
bring in 2.7.6 scheduler changes, don't count tasks with UNKNOWN depe…
alexyu0 Apr 9, 2020
5a9fee4
fix interpolation import
alexyu0 Apr 10, 2020
5c6bade
use getattr for param_visiblities
alexyu0 Apr 10, 2020
db2793b
bump version
alexyu0 Apr 11, 2020
f0c9824
don't bring in 2.7.6 changes
alexyu0 Apr 14, 2020
e1f13d8
unit tests for unknown state handling
alexyu0 Apr 16, 2020
f385a06
worker keep alive for test
alexyu0 Apr 16, 2020
fe45dc0
Merge pull request #13 from Affirm/alexyu-failed-deps-not-pending
alexyu0 Apr 17, 2020
dfae239
wrap add multiprocess in fork lock
alexyu0 Jan 13, 2021
9a81f9e
version bump
alexyu0 Jan 19, 2021
6e52c99
Merge pull request #14 from Affirm/alexyu-luigi-thread-lock
alexyu0 Feb 1, 2021
ce3c10f
luigi bobapki http adapter
andrewdanks Apr 14, 2022
c5edb70
bump version again
andrewdanks Apr 14, 2022
03e58a1
Merge pull request #16 from Affirm/cert_verify
andrewdanks Apr 14, 2022
4d09e53
fix enum34 dependency
hugues-aff Jun 29, 2022
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
worker keep alive for test
alexyu0 committed Apr 16, 2020

Verified

This commit was signed with the committer’s verified signature. The key has expired.
RomainMuller Romain Marcadier
commit f385a065aec638a30f1bc98a2fb0d11c2910d9c4
11 changes: 8 additions & 3 deletions test/unknown_state_handling_test.py
Original file line number Diff line number Diff line change
@@ -21,7 +21,6 @@ class FailInRequires(luigi.Task):
def requires(self):
print('failing')
raise Exception
return [DummyRequires()]

def run(self):
print('running')
@@ -46,8 +45,14 @@ def run(self):
class UnknownStateTest(LuigiTestCase):
def setUp(self):
super(UnknownStateTest, self).setUp()
self.scheduler = luigi.scheduler.Scheduler(prune_on_get_work=False)
self.worker = luigi.worker.Worker(scheduler=self.scheduler)
self.scheduler = luigi.scheduler.Scheduler(
prune_on_get_work=False,
retry_count=1
)
self.worker = luigi.worker.Worker(
scheduler=self.scheduler,
keep_alive=True
)

def run_task(self, task):
self.worker.add(task) # schedule