Skip to content

Commit ffc348f

Browse files
committed
feat: added definitions of summary tables (JobDB and PilotAgentsDB)
1 parent 57d83c5 commit ffc348f

2 files changed

Lines changed: 36 additions & 0 deletions

File tree

diracx-db/src/diracx/db/sql/job/schema.py

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
ForeignKey,
77
Index,
88
Integer,
9+
PrimaryKeyConstraint,
910
String,
1011
Text,
1112
)
@@ -156,3 +157,29 @@ class JobCommands(JobDBBase):
156157
status = Column("Status", String(64), default="Received")
157158
reception_time = Column("ReceptionTime", DateTime, primary_key=True)
158159
execution_time = NullColumn("ExecutionTime", DateTime)
160+
161+
162+
class JobsHistorySummary(JobDBBase):
163+
__tablename__ = "JobsHistorySummary"
164+
status = Column("Status", String(32))
165+
site = Column("Site", String(100))
166+
owner = Column("Owner", String(32))
167+
owner_group = Column("OwnerGroup", String(128))
168+
job_group = Column("JobGroup", String(32))
169+
job_type = Column("JobType", String(32))
170+
application_status = Column("ApplicationStatus", String(255))
171+
minor_status = Column("MinorStatus", String(128))
172+
job_count = Column("JobCount", Integer)
173+
reschedule_sum = Column("RescheduleSum", Integer)
174+
__table_args__ = (
175+
PrimaryKeyConstraint(
176+
"Status",
177+
"Site",
178+
"Owner",
179+
"OwnerGroup",
180+
"JobGroup",
181+
"JobType",
182+
"ApplicationStatus",
183+
"MinorStatus",
184+
),
185+
)

diracx-db/src/diracx/db/sql/pilot_agents/schema.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,3 +58,12 @@ class PilotOutput(PilotAgentsDBBase):
5858
pilot_id = Column("PilotID", Integer, primary_key=True)
5959
std_output = Column("StdOutput", Text)
6060
std_error = Column("StdError", Text)
61+
62+
63+
class PilotsHistorySummary(PilotAgentsDBBase):
64+
__tablename__ = "PilotsHistorySummary"
65+
66+
grid_site = Column("GridSite", String(128), primary_key=True)
67+
grid_type = Column("GridType", String(32), primary_key=True)
68+
status = Column("Status", String(32), primary_key=True)
69+
pilot_count = Column("PilotCount", Integer)

0 commit comments

Comments
 (0)