def _setup_ipc()

in mapillary_tools/upload.py [0:0]

• 21 lines of code
• 1 McCabe index (conditional complexity)

def _setup_ipc(emitter: uploader.EventEmitter):
    @emitter.on("upload_start")
    def upload_start(payload: uploader.Progress):
        type: uploader.EventName = "upload_start"
        LOG.debug(f"Sending {type} via IPC: {payload}")
        ipc.send(type, payload)

    @emitter.on("upload_fetch_offset")
    def upload_fetch_offset(payload: uploader.Progress) -> None:
        type: uploader.EventName = "upload_fetch_offset"
        LOG.debug(f"Sending {type} via IPC: {payload}")
        ipc.send(type, payload)

    @emitter.on("upload_progress")
    def upload_progress(payload: uploader.Progress):
        type: uploader.EventName = "upload_progress"
        LOG.debug(f"Sending {type} via IPC: {payload}")
        ipc.send(type, payload)

    @emitter.on("upload_end")
    def upload_end(payload: uploader.Progress) -> None:
        type: uploader.EventName = "upload_end"
        LOG.debug(f"Sending {type} via IPC: {payload}")
        ipc.send(type, payload)