Skip to content

Commit 332fc3e

Browse files
committed
Consume transform title and logs url from messages returned by service
1 parent fd74676 commit 332fc3e

File tree

3 files changed

+4
-1
lines changed

3 files changed

+4
-1
lines changed

servicex/app/transforms.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ def list(
7171
for t in transforms:
7272
if not complete or complete and t.status == Status.complete:
7373
table.add_row(
74-
t.request_id, "Not implemented", t.status, str(t.files_completed)
74+
t.request_id, t.title, t.status, str(t.files_completed)
7575
)
7676

7777
rich.print(table)

servicex/models.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -107,6 +107,7 @@ class TransformStatus(BaseModel):
107107
"""
108108
request_id: str
109109
did: str
110+
title: Optional[str]
110111
selection: str
111112
tree_name: Optional[str] = Field(alias="tree-name")
112113
image: str
@@ -125,6 +126,7 @@ class TransformStatus(BaseModel):
125126
minio_secured: Optional[bool] = Field(alias="minio-secured")
126127
minio_access_key: Optional[str] = Field(alias="minio-access-key")
127128
minio_secret_key: Optional[str] = Field(alias="minio-secret-key")
129+
log_url: Optional[str] = Field(alias="log-url")
128130

129131
@validator("finish_time", pre=True)
130132
def parse_finish_time(cls, v):

servicex/servicex_adapter.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -122,5 +122,6 @@ async def get_transform_status(self, request_id: str) -> TransformStatus:
122122
raise AuthorizationError(f"Not authorized to access serviceX at {self.url}")
123123
if r.status_code == 404:
124124
raise ValueError(f"Transform ID {request_id} not found")
125+
125126
status = TransformStatus(**r.json())
126127
return status

0 commit comments

Comments
 (0)