code: def CreateTaskStorage(self, task):
      
      if task.identifier in self._task_storage_writers:
        raise IOError('Storage writer for task: {0:s} already exists.'.format(
            task.identifier))
  
      storage_writer = FakeStorageWriter(
          self._session, storage_type=definitions.STORAGE_TYPE_TASK, task=task)
      self._task_storage_writers[task.identifier] = storage_writer
      return storage_writer
docs: Creates a task storage.
  
      Args:
        task (Task): task.
  
      Returns:
        FakeStorageWriter: storage writer.
  
      Raises:
        IOError: if the task storage already exists.
        OSError: if the task storage already exists.