code: def create_queue(self, credentials):
          
          if credentials:
              session = self.session or aiohttp.ClientSession(loop=self.event_loop)
              return Queue(
                  options={
                      'credentials': credentials,
                      'rootUrl': self.config['taskcluster_root_url'],
                  },
                  session=session
              )
docs: Create a taskcluster queue.
  
          Args:
              credentials (dict): taskcluster credentials.