Skip to content

Commit c3efcf0

Browse files
🧪 introduce retrying for each user in e2e clean up jobs (#130)
* update workflow before publishing python package * fix dependency issue and bump version * point to website in project description * fix broken dependency * improve doc * add github token to download artifacts * ensure only read-access @wvangeit * yet another attempt at downloading artifacts * make sure to use repo that ran the trigger wf * another attempt at fixing * change owner * allow publishing to testpypi also when pr * minor change * revert minor (but breaking) change * minor fix * add debug messages * another debug message * hopefully the final version * final fix * minor fix * move master and tag to individual jobs * add debug messages * dev->post * add python script for determining semantic version * minor changes * minor changes * improve error handling and add version file to artifacts * check if release * minor fix * ensure to enter venv * also when tagging * source venv in publishin workflow * ensure only master * add script for testing 'pure' semver * adapt workflows to new python script * minor change * attempt to evaluate expressions correctly * several fixes to fix tests * ensure repo is checked out in publish workflow * several small fixes * cleanup * debug * minor cleanup * mionr changes * add debug message * minor change * minor change * yet another try * minor change * minor change * minor change * mionr change * minor changes * correct workflow run id * cosmetic change * avoid using gh * change to a single job for publishing * minor cleanup * swap loops in clean up jobs * correction
1 parent fb7447c commit c3efcf0

File tree

1 file changed

+16
-16
lines changed

1 file changed

+16
-16
lines changed

‎clients/python/test/e2e/ci/e2e/e2e/postprocess.py‎

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -210,22 +210,22 @@ def clean_up_jobs(artifacts_dir: Path, retry_minutes: Optional[PositiveInt] = No
210210
cfg = {s: dict(obj.items(s)) for s in obj.sections()}
211211
server_config = ServerSettings.model_validate(cfg.get("server"))
212212
servers.add(server_config)
213-
for attempt in Retrying(
214-
retry=retry_if_exception_type(osparc.ApiException),
215-
stop=stop_after_delay(timedelta(minutes=retry_minutes))
216-
if retry_minutes
217-
else stop_after_attempt(1),
218-
):
219-
with attempt:
220-
for server_config in servers:
221-
config = osparc.Configuration(
222-
host=server_config.host,
223-
username=server_config.key,
224-
password=server_config.secret,
225-
)
226-
msg = "Cleaning up jobs for user: "
227-
msg += f"\n{server_config.model_dump_json(indent=1)}"
228-
typer.echo(msg)
213+
for server_config in servers:
214+
config = osparc.Configuration(
215+
host=server_config.host,
216+
username=server_config.key,
217+
password=server_config.secret,
218+
)
219+
msg = "Cleaning up jobs for user: "
220+
msg += f"\n{server_config.model_dump_json(indent=1)}"
221+
typer.echo(msg)
222+
for attempt in Retrying(
223+
retry=retry_if_exception_type(osparc.ApiException),
224+
stop=stop_after_delay(timedelta(minutes=retry_minutes))
225+
if retry_minutes
226+
else stop_after_attempt(1),
227+
):
228+
with attempt:
229229
with osparc.ApiClient(config) as api_client:
230230
solvers_api = osparc.SolversApi(api_client)
231231
assert isinstance(

0 commit comments

Comments
 (0)