8000 Hash change guards by tclose · Pull Request #698 · nipype/pydra · GitHub
[go: up one dir, main page]

Skip to content

Hash change guards #698

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

Merged
merged 30 commits into from
Mar 8, 2024
Merged
Changes from 1 commit
Commits
Show all changes
30 commits
Select commit Hold shift + click to select a range
3a72666
Implemented hash-change guards in TaskBase._run()
tclose Feb 24, 2024
b378f83
added hash guards to workflow execution (i.e. on workflow inputs)
tclose Feb 24, 2024
5aaf62f
reworked error message for blocked upstream tasks to specifiy which t…
tclose Feb 24, 2024
0397a18
touched up messages for hash change errors
tclose Feb 24, 2024
1d77f4b
replaced attrs.evolve with manual setattr of inputs within Task._run(…
tclose Feb 24, 2024
e2d009b
updated explicit hashes in unittests to match new values produced by …
tclose Feb 24, 2024
48d68f5
added a sleep to alter_x to make sure it runs after identity
tclose Feb 24, 2024
1a9eed0
fix up
tclose Feb 24, 2024
d76bb3d
[skip ci] updates comment
tclose Feb 24, 2024
6e1f030
upped sleep
tclose Feb 24, 2024
6717d85
added random in to ensure that alter_x finishes after identity
tclose Feb 24, 2024
1cd9491
added more reruns to test_hash_changes_in_workflow_graph
tclose Feb 24, 2024
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
Update pydra/engine/tests/test_submitter.py
Co-authored-by: Chris Markiewicz <effigies@gmail.com>
  • Loading branch information
tclose and effigies committed Feb 24, 2024
commit c282d3e445d9839c872d690be87565220be1deb5
4 changes: 2 additions & 2 deletions pydra/engine/tests/test_submitter.py
Original file line number Diff line number Diff line change
Expand Up @@ -593,8 +593,8 @@ class Unstable:
value: int # type: ignore

def __bytes_repr__(self, cache) -> ty.Iterator[bytes]:
"""Bytes repr based on time-stamp -> inherently unstable"""
yield struct.pack("!I", int(time.time()))
"""Random 128-bit bytestring"""
yield random.randbytes(16)

@mark.task
def unstable_input(unstable: Unstable) -> int:
Expand Down
0