code: def publish(self, distribution, storage=""):
          
          try:
              return self._publishes[distribution]
          except KeyError:
              self._publishes[distribution] = Publish(self.client, distribution, timestamp=self.timestamp, storage=(storage or self.storage))
              return self._publishes[distribution]
docs: Get or create publish