Skip to content

Commit 4863b78

Browse files
committed
Remove local storage publisher
1 parent ade4611 commit 4863b78

2 files changed

Lines changed: 6 additions & 5 deletions

File tree

src/isar/storage/uploader.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -182,9 +182,10 @@ def should_upload(_item):
182182
self._internal_upload_queue.remove(item)
183183
elif isinstance(item, BlobItem):
184184
inspection_path = self._upload(item)
185-
self._publish_inspection_result(
186-
inspection=item.inspection, inspection_path=inspection_path
187-
)
185+
if type(inspection_path) is not str:
186+
self._publish_inspection_result(
187+
inspection=item.inspection, inspection_path=inspection_path
188+
)
188189
else:
189190
self.logger.warning(
190191
f"Unable to process upload item as its type {type(item).__name__} is not supported"
@@ -223,7 +224,7 @@ def _publish_inspection_value(self, inspection: InspectionValue) -> None:
223224
)
224225

225226
def _publish_inspection_result(
226-
self, inspection: InspectionBlob, inspection_path: Union[str, dict]
227+
self, inspection: InspectionBlob, inspection_path: Union[dict]
227228
) -> None:
228229
"""Publishes the reference of the inspection result to the MQTT Broker
229230
along with the analysis type

src/robot_interface/telemetry/payloads.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ class InspectionResultPayload:
109109
isar_id: str
110110
robot_name: str
111111
inspection_id: str
112-
inspection_path: Union[str, dict]
112+
inspection_path: Union[dict]
113113
installation_code: str
114114
tag_id: Optional[str]
115115
inspection_type: Optional[str]

0 commit comments

Comments
 (0)