def METHOD_NAME(self):
    msg = {
        "id": "1-foo",
        "status": "running",
        "job_id": "0000000000000000000000000000000000000000",
    }
    self.status_repo.process_message(msg)
    self.assertEqual(
        self.status_repo.get_all_task_data("1-foo"), [{"status": "running"}]
    )