Add optional pipeline parameter to set_state.
Added job_id property, storing the id of the currently executing job.
Added Worker.get_current_job() convenience method.