make the common part of start_worker indeed, common

[shadeofblue]

No description provided.

[azawlocki]

Nice! I don't have any suggestions, except maybe to also make emitting the WorkerFinished event part of the new start_worker, along the lines of:

async def start_worker(...):
   
    async def _worker(...):
        # no changes
        ...
   
    async def _wrapped_worker(agrement, node_info):
        self.emit(WorkerStarted(agreement.id))
        try:
            await _worker(agreement, node_info)
            self.emit(WorkerFinished(agreement.id)
        except Exception:
            self.emit(WorkerFinished(agreement.id, exc_info=sys.exc_info())
            raise
            
    return await job.agreements_pool.use_agreement(
        lambda agreement, node: loop.create_task(_wrapped_worker(agreement, node))
    )