Skip to content

Commit a7808f7

Browse files
committed
refactor: simplify run event persistence calls
1 parent af61a7e commit a7808f7

2 files changed

Lines changed: 2 additions & 6 deletions

File tree

src/codealmanac/services/runs/service.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -118,30 +118,26 @@ def stream_attach(
118118
)
119119

120120
def record_event(self, request: RecordRunEventRequest) -> RunLogEvent:
121-
self.store.read(request.run_id)
122-
return self.store.append(
121+
return self.store.record_event(
123122
request.run_id,
124123
request.kind,
125124
request.message,
126125
request.harness_event,
127126
)
128127

129128
def mark_running(self, request: MarkRunRunningRequest) -> RunRecord:
130-
self.store.read(request.run_id)
131129
return self.store.mark_running(request.run_id)
132130

133131
def record_harness_transcript(
134132
self,
135133
request: RecordRunHarnessTranscriptRequest,
136134
) -> RunRecord:
137-
self.store.read(request.run_id)
138135
return self.store.record_harness_transcript(
139136
request.run_id,
140137
request.transcript,
141138
)
142139

143140
def finish(self, request: FinishRunRequest) -> RunRecord:
144-
self.store.read(request.run_id)
145141
return self.store.finish(
146142
request.run_id,
147143
request.status,

src/codealmanac/services/runs/store.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -169,7 +169,7 @@ def attach(self, run_id: str) -> RunAttachSnapshot:
169169
terminal=record.status in TERMINAL_RUN_STATUSES,
170170
)
171171

172-
def append(
172+
def record_event(
173173
self,
174174
run_id: str,
175175
kind: RunEventKind,

0 commit comments

Comments
 (0)