this repo has no description
bsky_activity: handle missing CIDs
+8
-1
+8
-1
firehose_utils.py
+8
-1
firehose_utils.py
···
69
69
70
70
for commit_op in payload['ops']:
71
71
op = commit_op.copy()
72
+
record = None
72
73
if op['cid'] is not None:
73
74
op['cid'] = op['cid'].encode('base32')
74
-
op['record'] = car_parsed.blocks[op['cid']]
75
+
record = car_parsed.blocks.get(op['cid'])
76
+
77
+
if record is not None:
78
+
op['record'] = record
79
+
else:
80
+
continue
81
+
75
82
yield message, op