Skip to content

Commit fe09e19

Browse files
fix: Fixed ClientWMS test and reversed TEST_DIRACX flag
1 parent 1447a20 commit fe09e19

File tree

4 files changed

+6
-5
lines changed

4 files changed

+6
-5
lines changed

.github/workflows/integration.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ jobs:
3838
- TEST_NAME: "Backward Compatibility"
3939
ARGS: CLIENT_INSTALLATION_BRANCH=rel-v8r0 PILOT_INSTALLATION_BRANCH=rel-v8r0
4040
- TEST_NAME: "NoTestDIRACX"
41-
ARGS: TEST_DIRACX=No
41+
ARGS: TEST_DIRACX=Yes
4242

4343
steps:
4444
- uses: actions/checkout@v4

integration_tests.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
"DIRACOSVER": "master",
3131
"DIRACOS_TARBALL_PATH": None,
3232
"TEST_HTTPS": "No",
33-
"TEST_DIRACX": "Yes",
33+
"TEST_DIRACX": "No",
3434
"DIRAC_FEWER_CFG_LOCKS": None,
3535
"DIRAC_USE_JSON_ENCODE": None,
3636
"INSTALLATION_BRANCH": "",

src/DIRAC/WorkloadManagementSystem/FutureClient/JobStateUpdateClient.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,11 +77,11 @@ def setJobApplicationStatus(self, jobID: str | int, appStatus: str, source: str
7777
def setJobAttribute(self, jobID: str | int, attribute: str, value: str):
7878
with DiracXClient() as api:
7979
if attribute == "Status":
80-
api.jobs.set_job_statuses(
80+
return api.jobs.set_job_statuses(
8181
{jobID: {datetime.now(tz=timezone.utc): {"Status": value}}},
8282
)
8383
else:
84-
api.jobs.patch_metadata({jobID: {attribute: value}})
84+
return api.jobs.patch_metadata({jobID: {attribute: value}})
8585

8686
@stripValueIfOK
8787
@convertToReturnValue

tests/Integration/WorkloadManagementSystem/Test_Client_WMS.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -449,7 +449,8 @@ def test_JobStateUpdateAndJobMonitoringMultiple(lfn: str) -> None:
449449

450450
res = jobMonitoringClient.getJobSummary(int(jobID))
451451
assert res["OK"], res["Message"]
452-
assert res["Value"]["Status"] == JobStatus.RUNNING
452+
assert res["Value"]["Status"] != JobStatus.RUNNING # NOT equal: timedelta = 0 compared to above
453+
assert res["Value"]["Status"] == JobStatus.MATCHED # Keep previous result
453454
finally:
454455
res = jobManagerClient.killJob(jobIDs)
455456
assert res["OK"], res["Message"]

0 commit comments

Comments
 (0)