def METHOD_NAME(self, pipe_e, script):
    '''Add a script that is currently executed by this worker
    Args:
        script (:class:`model.PipeElement`): Pipeline element that is related to script.
        script (:class:`model.Script`): Script that is executed.
    '''
    self.worker = self.dbm.get_worker_and_lock(self.lostconfig.worker_name)
    if self.worker.in_progress is not None:
        scripts = json.loads(self.worker.in_progress)
    else:
        scripts =  {}
    scripts[pipe_e.idx] = script.path
    self.worker.in_progress = json.dumps(scripts)
    if script.resources:
        if 'lock_all' in json.loads(script.resources):
            self._lock_worker()
    self.dbm.add(self.worker)
    self.dbm.commit()