Skip to content

feat(JobWrapper): Report the status of the job to DiracX#111

Merged
aldbr merged 19 commits intoDIRACGrid:mainfrom
Loxeris:diracx-job-statuses
Mar 11, 2026
Merged

feat(JobWrapper): Report the status of the job to DiracX#111
aldbr merged 19 commits intoDIRACGrid:mainfrom
Loxeris:diracx-job-statuses

Conversation

@Loxeris
Copy link
Member

@Loxeris Loxeris commented Feb 9, 2026

Reports the status of the job to DiracX using diracx-api.

closes #83

@Loxeris Loxeris force-pushed the diracx-job-statuses branch from 71983e2 to 2ff453b Compare February 9, 2026 17:19
Copy link
Contributor

@aldbr aldbr left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks @Loxeris, it's a good conversion from the existing DIRAC JobWrapper. Based on that, and my experience with it, I have a few comments to improve it.

@Loxeris Loxeris force-pushed the diracx-job-statuses branch from 2ff453b to 140b8bc Compare February 23, 2026 16:53
@Loxeris Loxeris force-pushed the diracx-job-statuses branch from 4e793fe to ae4abc4 Compare March 3, 2026 15:41
@Loxeris Loxeris force-pushed the diracx-job-statuses branch from a6ac83f to c7b7188 Compare March 4, 2026 10:19
@Loxeris Loxeris marked this pull request as ready for review March 4, 2026 10:54
@Loxeris Loxeris requested a review from aldbr March 4, 2026 10:54
@Loxeris
Copy link
Member Author

Loxeris commented Mar 10, 2026

Tested and working on CTAO certification instance

@Loxeris Loxeris force-pushed the diracx-job-statuses branch from c0f8f4d to 726cd8f Compare March 11, 2026 13:09
Copy link
Contributor

@aldbr aldbr left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This is my very last comment I think, it looks good to me 🙂
Thanks for your work @Loxeris

class JobReport:
"""JobReport."""

def __init__(self, job_id: int, source: str, client: AsyncDiracClient | None) -> None:
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think the client is mandatory here.
Also, you are acting as if the client was mandatory already.

Suggested change
def __init__(self, job_id: int, source: str, client: AsyncDiracClient | None) -> None:
def __init__(self, job_id: int, source: str, client: AsyncDiracClient) -> None:

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Right! I had set the client=None in the JobWrapper for local but it would make sense to just use the _diracx_client

@aldbr aldbr merged commit 4cf8c29 into DIRACGrid:main Mar 11, 2026
4 checks passed
@Loxeris Loxeris deleted the diracx-job-statuses branch March 16, 2026 09:44
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

The job wrapper should report the status of the job to DiracX

2 participants