Skip to content

fix: Up wait times on all tasks to prevent unwanted timeouts #189

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

Open
NickolausDS wants to merge 1 commit into
base: main
Choose a base branch
from
Open

fix: Up wait times on all tasks to prevent unwanted timeouts #189

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
10 changes: 5 additions & 5 deletions gladier_xpcs/flows/flow_boost.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
from gladier import GladierBaseClient, generate_flow_definition

@generate_flow_definition(modifiers={
# 'publishv2_gather_metadata': {
# 'payload': '$.GatherXpcsMetadata.details.results[0].output',
# 'WaitTime': 600,
# }
'publishv2_gather_metadata': {
# 'payload': '$.GatherXpcsMetadata.details.results[0].output',
'WaitTime': 86400,
}
})
class XPCSBoost(GladierBaseClient):
globus_group = '368beb47-c9c5-11e9-b455-0efb3ba9a670'
Expand All @@ -17,5 +17,5 @@ class XPCSBoost(GladierBaseClient):
'gladier_xpcs.tools.gather_xpcs_metadata.GatherXPCSMetadata',
# Publication is currently broken due to the destination collection being down.
# Uncomment this to re-enable
# 'gladier_tools.publish.Publishv2',
'gladier_tools.publish.Publishv2',
]
8 changes: 5 additions & 3 deletions gladier_xpcs/tools/gather_xpcs_metadata.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -268,9 +268,11 @@ def gather(dataframe):


@generate_flow_definition(modifiers={
gather_xpcs_metadata: {'endpoint': 'login_node_endpoint',
'ExceptionOnActionFailure': True,
}
gather_xpcs_metadata: {
'endpoint': 'login_node_endpoint',
'ExceptionOnActionFailure': True,
'WaitTime': 86400,
}
})
class GatherXPCSMetadata(GladierBaseTool):

Expand Down
2 changes: 1 addition & 1 deletion gladier_xpcs/tools/plot.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ def make_corr_plots(**data):


@generate_flow_definition(modifiers={
'make_corr_plots': {'WaitTime': 28800}
'make_corr_plots': {'WaitTime': 86400}
})
class MakeCorrPlots(GladierBaseTool):
required_input = [
Expand Down
2 changes: 1 addition & 1 deletion gladier_xpcs/tools/result_transfer.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ class ResultTransfer(GladierBaseTool):
'DATA.$': '$.input.result_transfer.transfer_items',
},
'ResultPath': '$.ResultTransferDoTransfer',
'WaitTime': 600,
'WaitTime': 86400,
"Next": "ResultTransferDone",
},
"ResultTransferSkipTransfer": {
Expand Down
2 changes: 1 addition & 1 deletion gladier_xpcs/tools/source_transfer.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ class SourceTransfer(GladierBaseTool):
'DATA.$': '$.input.source_transfer.transfer_items',
},
'ResultPath': '$.SourceTransfer',
'WaitTime': 600,
'WaitTime': 86400,
'End': True
},
}
Expand Down
2 changes: 1 addition & 1 deletion gladier_xpcs/tools/xpcs_boost_corr.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ def xpcs_boost_corr(**data):


@generate_flow_definition(modifiers={
xpcs_boost_corr: {'WaitTime': 7200,
xpcs_boost_corr: {'WaitTime': 86400,
'ExceptionOnActionFailure': True}
})
class BoostCorr(GladierBaseTool):
Expand Down