def _event_stream()

in services/ui_backend_service/data/refiner/refinery.py [0:0]

• 4 lines of code
• 3 McCabe index (conditional complexity)

        def _event_stream(event):
            if event.get("type") == "error" and event.get("key"):
                # Get last element from cache key which usually translates to "target"
                target = event["key"].split(':')[-1:][0]
                errors[target] = event