05ecca5cceb5d0dddb9ca5c2279a783989b8f18c,parlai/mturk/core/mturk_data_handler.py,MTurkDataHandler,log_start_task,#MTurkDataHandler#Any#Any#Any#,290

Before Change

        conn.commit()

    def log_start_task(self, worker_id, assignment_id, conversation_id):
        conn = self._get_connection()
        c = conn.cursor()
        c.execute("""UPDATE pairings SET status = ?, task_start = ?,
                     conversation_id = ? WHERE worker_id = ?
                     AND assignment_id = ?;""",
                  (AssignState.STATUS_IN_TASK, time.time(), conversation_id,
                   worker_id, assignment_id))
        conn.commit()

    def log_award_amount(self, worker_id, assignment_id, amount, reason):
        conn = self._get_connection()
        c = conn.cursor()

After Change

            conn.commit()

    def log_start_task(self, worker_id, assignment_id, conversation_id):
        with self.table_access_condition:
            conn = self._get_connection()
            c = conn.cursor()
            c.execute("""UPDATE pairings SET status = ?, task_start = ?,
                         conversation_id = ? WHERE worker_id = ?
                         AND assignment_id = ?;""",
                      (AssignState.STATUS_IN_TASK, time.time(),
                       conversation_id, worker_id, assignment_id))
            conn.commit()

    def log_award_amount(self, worker_id, assignment_id, amount, reason):
        with self.table_access_condition:
            conn = self._get_connection()
            c = conn.cursor()

Instances