async def METHOD_NAME(self, connector_tar_file: File):
    connector_image_tag = f"airbyte/{self.context.connector.technical_name}:dev"
    self.context.logger.info("Load the connector image to the docker host")
    await environments.load_image_to_docker_host(self.context, connector_tar_file, connector_image_tag)
    self.context.logger.info("Successfully loaded the connector image to the docker host.")