Skip to content

Commit e139084

Browse files
authored
1000 fix key error 2 (#1016)
* Doc updates * fix error * Fixed wrong exception handling implementation.
1 parent 360f304 commit e139084

File tree

2 files changed

+8
-9
lines changed

2 files changed

+8
-9
lines changed

samples/router/src/analytics.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,14 @@
11
import asyncio
2-
import time
32
import os
3+
import time
44

55
from savant_rs.logging import LogLevel, log
66
from savant_rs.match_query import MatchQuery as Q
77
from savant_rs.primitives import BorrowedVideoObject, VideoFrame
88
from savant_rs.zmq import NonBlockingReader, ReaderConfigBuilder, ReaderResultMessage
99

10+
socket_url = os.getenv('ZMQ_SRC_ENDPOINT')
1011

11-
socket_url = os.getenv("ZMQ_SRC_ENDPOINT")
1212

1313
async def reader():
1414
reader_config = ReaderConfigBuilder(socket_url).build()
@@ -35,15 +35,15 @@ async def reader():
3535
processed_at = time.time() * 1000
3636
log(
3737
LogLevel.Info,
38-
"analytics::time_delta",
39-
f"{frame.source_id} {frame.pts} {int(processed_at - created_at)} {object_info}",
38+
'analytics::time_delta',
39+
f'{frame.source_id} {frame.pts} {int(processed_at - created_at)} {object_info}',
4040
)
41-
log(LogLevel.Info, "analytics::frame::json", f"{frame.json}")
41+
log(LogLevel.Info, 'analytics::frame::json', f'{frame.json}')
4242

4343

4444
loop = asyncio.new_event_loop()
4545
try:
4646
loop.run_until_complete(reader())
4747
finally:
4848
loop.run_until_complete(loop.shutdown_asyncgens())
49-
loop.close()
49+
loop.close()

savant/deepstream/pipeline.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1031,11 +1031,10 @@ def _nvds_obj_id(_obj_meta: pyds.NvDsObjectMeta) -> str:
10311031
# TODO: fix it GitHub issue #1000
10321032
# this is a workaround to fix the issue (we just prevent circular references)
10331033
obj = video_frame.get_object(obj_id)
1034-
parent = video_frame.get_object(nvds_object_id_map[parent_id])
10351034
self._logger.warning(
1036-
'Failed to set parent for object %s: %s, exception: %s',
1035+
'Failed to set parent %s for object %s: exception: %s',
1036+
parent_id,
10371037
(obj.id, obj.namespace, obj.label, obj.track_id),
1038-
(parent.id, parent.namespace, parent.label, parent.track_id),
10391038
e,
10401039
)
10411040

0 commit comments

Comments
 (0)