Skip to content

[POC] Pilot legacy logging #596

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

Open
wants to merge 33 commits into
base: main
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
33 commits
Select commit Hold shift + click to select a range
bdf5b13
feat: Add pilot management: create/delete/patch and query
Robin-Van-de-Merghel Jun 13, 2025
6589415
feat: Fixes and now use of search engine instead of DIY fetch records
Robin-Van-de-Merghel Jun 15, 2025
a49b383
fix: Fixed models and reoranizing db functions
Robin-Van-de-Merghel Jun 15, 2025
76d4e71
fix: Fixed possible bad behaviour
Robin-Van-de-Merghel Jun 16, 2025
b15e6d8
fix: Small typo fix
Robin-Van-de-Merghel Jun 18, 2025
e20a15c
fix: Some minor fixes including adding PILOT_STATUS
Robin-Van-de-Merghel Jun 19, 2025
07274f2
fix: Small fixes and rename function about pilot and job association
Robin-Van-de-Merghel Jun 23, 2025
cb840de
fix: Small fix in a test
Robin-Van-de-Merghel Jun 23, 2025
a851e71
fix: Lot of fixes, refactoring tests, and modifying access policy to …
Robin-Van-de-Merghel Jun 25, 2025
9b75a84
refactor: Refactored delete pilot endpoints
Robin-Van-de-Merghel Jun 25, 2025
9df6300
feat: We can search for job associated to a pilot and vice versa
Robin-Van-de-Merghel Jun 26, 2025
65346df
feat: Better pilot deletion (following DIRAC behaviour)
Robin-Van-de-Merghel Jun 27, 2025
ec450b8
fix: Generate client
Robin-Van-de-Merghel Jun 27, 2025
507a08c
fix: Syntax error
Robin-Van-de-Merghel Jun 27, 2025
7e22312
fix: Removed from management
Jun 30, 2025
941df03
fix: Changed search endpoint
Jun 30, 2025
fd52332
fix: Change from status reason to status (cf dirac-admin-add-pilot)
Jul 1, 2025
0d54285
fix: Removed vo from creation, and better policy
Jul 4, 2025
85d3c4a
feat: Better policy, to support also jobs
Jul 4, 2025
fb7f4d9
feat: Add pilot summary, and refactor jobs one
Jul 4, 2025
4df97ff
feat: Add legacy pilot support in management (dirac-admin-add-pilot)
Jul 4, 2025
3ecd3b3
chore: Removed association of a job with a pilot because it's internal
Jul 4, 2025
2a72da1
[pre-commit.ci] auto fixes from pre-commit.com hooks
pre-commit-ci[bot] Jul 4, 2025
7ca26a0
fix: Fixes to pass CI
Jul 8, 2025
c2e4992
fix: Patch client to use in in DIRAC
Jul 14, 2025
b60f4f2
fix: Minor fixes, and testing pilot summary
Jul 14, 2025
6674d37
fix Fixed client (lack a comma)
Jul 16, 2025
3e358bb
fix: Add patch for the pilot client
Robin-Van-de-Merghel Aug 1, 2025
cae7411
fix: Use also VO as parameter (in case DIRAC has a bad VO)
Robin-Van-de-Merghel Aug 1, 2025
8a978fa
fix: Use also VO as parameter (in case DIRAC has a bad VO)
Robin-Van-de-Merghel Aug 1, 2025
82c552c
feat: Add pilot management: create/delete/patch and query
Robin-Van-de-Merghel Jun 13, 2025
619e336
feat: POC to have legacy pilots sending logs
Robin-Van-de-Merghel Jul 30, 2025
98d9003
fix: Parameter uplication in pilot management
Robin-Van-de-Merghel Aug 1, 2025
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
15 changes: 14 additions & 1 deletion diracx-client/src/diracx/client/_generated/_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,14 @@
from . import models as _models
from ._configuration import DiracConfiguration
from ._utils.serialization import Deserializer, Serializer
from .operations import AuthOperations, ConfigOperations, JobsOperations, WellKnownOperations
from .operations import (
AuthOperations,
ConfigOperations,
JobsOperations,
PilotsLegacyOperations,
PilotsOperations,
WellKnownOperations,
)


class Dirac: # pylint: disable=client-accepts-api-version-keyword
Expand All @@ -29,6 +36,10 @@ class Dirac: # pylint: disable=client-accepts-api-version-keyword
:vartype config: _generated.operations.ConfigOperations
:ivar jobs: JobsOperations operations
:vartype jobs: _generated.operations.JobsOperations
:ivar pilots: PilotsOperations operations
:vartype pilots: _generated.operations.PilotsOperations
:ivar pilots_legacy: PilotsLegacyOperations operations
:vartype pilots_legacy: _generated.operations.PilotsLegacyOperations
:keyword endpoint: Service URL. Required. Default value is "".
:paramtype endpoint: str
"""
Expand Down Expand Up @@ -65,6 +76,8 @@ def __init__( # pylint: disable=missing-client-constructor-parameter-credential
self.auth = AuthOperations(self._client, self._config, self._serialize, self._deserialize)
self.config = ConfigOperations(self._client, self._config, self._serialize, self._deserialize)
self.jobs = JobsOperations(self._client, self._config, self._serialize, self._deserialize)
self.pilots = PilotsOperations(self._client, self._config, self._serialize, self._deserialize)
self.pilots_legacy = PilotsLegacyOperations(self._client, self._config, self._serialize, self._deserialize)

def send_request(self, request: HttpRequest, *, stream: bool = False, **kwargs: Any) -> HttpResponse:
"""Runs the network request through the client's chained policies.
Expand Down
15 changes: 14 additions & 1 deletion diracx-client/src/diracx/client/_generated/aio/_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,14 @@
from .. import models as _models
from .._utils.serialization import Deserializer, Serializer
from ._configuration import DiracConfiguration
from .operations import AuthOperations, ConfigOperations, JobsOperations, WellKnownOperations
from .operations import (
AuthOperations,
ConfigOperations,
JobsOperations,
PilotsLegacyOperations,
PilotsOperations,
WellKnownOperations,
)


class Dirac: # pylint: disable=client-accepts-api-version-keyword
Expand All @@ -29,6 +36,10 @@ class Dirac: # pylint: disable=client-accepts-api-version-keyword
:vartype config: _generated.aio.operations.ConfigOperations
:ivar jobs: JobsOperations operations
:vartype jobs: _generated.aio.operations.JobsOperations
:ivar pilots: PilotsOperations operations
:vartype pilots: _generated.aio.operations.PilotsOperations
:ivar pilots_legacy: PilotsLegacyOperations operations
:vartype pilots_legacy: _generated.aio.operations.PilotsLegacyOperations
:keyword endpoint: Service URL. Required. Default value is "".
:paramtype endpoint: str
"""
Expand Down Expand Up @@ -65,6 +76,8 @@ def __init__( # pylint: disable=missing-client-constructor-parameter-credential
self.auth = AuthOperations(self._client, self._config, self._serialize, self._deserialize)
self.config = ConfigOperations(self._client, self._config, self._serialize, self._deserialize)
self.jobs = JobsOperations(self._client, self._config, self._serialize, self._deserialize)
self.pilots = PilotsOperations(self._client, self._config, self._serialize, self._deserialize)
self.pilots_legacy = PilotsLegacyOperations(self._client, self._config, self._serialize, self._deserialize)

def send_request(
self, request: HttpRequest, *, stream: bool = False, **kwargs: Any
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,8 @@
from ._operations import AuthOperations # type: ignore
from ._operations import ConfigOperations # type: ignore
from ._operations import JobsOperations # type: ignore
from ._operations import PilotsOperations # type: ignore
from ._operations import PilotsLegacyOperations # type: ignore

from ._patch import __all__ as _patch_all
from ._patch import *
Expand All @@ -24,6 +26,8 @@
"AuthOperations",
"ConfigOperations",
"JobsOperations",
"PilotsOperations",
"PilotsLegacyOperations",
]
__all__.extend([p for p in _patch_all if p not in __all__]) # pyright: ignore
_patch_sdk()
Loading
Loading