Skip to content

Commit 4a2d917

Browse files
authored
[DL Streamer Pipeline Server] Bugfix: appsink destination and publisher configuration (open-edge-platform#197)
1 parent 6e16a15 commit 4a2d917

File tree

1 file changed

+4
-6
lines changed
  • microservices/dlstreamer-pipeline-server/src/publisher

1 file changed

+4
-6
lines changed

microservices/dlstreamer-pipeline-server/src/publisher/publisher.py

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -190,13 +190,11 @@ def _get_publishers(self):
190190
if re.search(pattern, launch_string):
191191
self.log.info("appsink destination found. Publisher will be initialized")
192192
# identify DLStreamer pipeline server publishers and pop them from the request
193-
if self.request is not None:
193+
if self.request is not None and "destination" in self.request:
194194
frame_destination = copy.deepcopy(self.request.get("destination").get("frame", None))
195195
meta_destination = copy.deepcopy(self.request.get("destination").get("metadata", None))
196-
if frame_destination:
197-
self._get_frame_publisher_config(frame_destination)
198-
if meta_destination:
199-
self._get_meta_publisher_config(meta_destination)
196+
self._get_frame_publisher_config(frame_destination)
197+
self._get_meta_publisher_config(meta_destination)
200198
if not self.request["destination"]:
201199
self.request.pop("destination")
202200

@@ -636,4 +634,4 @@ def _add_s3_metadata(self, meta_data: Dict[str, str], s3_cfg: Dict[str, str]) ->
636634
'key': s3_cfg.get('folder_prefix', "dlstreamer_pipeline_server")+f"/{meta_data['img_handle']}"+ext,
637635
}
638636
}
639-
return s3_metadata
637+
return s3_metadata

0 commit comments

Comments
 (0)