def METHOD_NAME(self):
    msg = {"id": "1-foo", "status": "started", "output_dir": "/fake/path"}
    self.status_repo._handle_task_started(msg)
    self.assertEqual(
        self.status_repo.get_all_task_data("1-foo"),
        [{"status": "started", "output_dir": "/fake/path"}],
    )