text: #!/usr/bin/python
  #
  # Copyright 2018-2020 Polyaxon, Inc.
  #
  # Licensed under the Apache License, Version 2.0 (the "License");
  # you may not use this file except in compliance with the License.
  # You may obtain a copy of the License at
  #
  #      http://www.apache.org/licenses/LICENSE-2.0
  #
  # Unless required by applicable law or agreed to in writing, software
  # distributed under the License is distributed on an "AS IS" BASIS,
  # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  # See the License for the specific language governing permissions and
  # limitations under the License.
  
  # coding: utf-8
  
  """
      Polyaxon SDKs and REST API specification.
  
      Polyaxon SDKs and REST API specification.  # noqa: E501
  
      The version of the OpenAPI document: 1.1.7
      Contact: contact@polyaxon.com
      Generated by: https://openapi-generator.tech
  """
  
  
  from __future__ import absolute_import
  
  import re  # noqa: F401
  
  # python 2 and python 3 compatibility library
  import six
  
  from polyaxon_sdk.api_client import ApiClient
  from polyaxon_sdk.exceptions import ApiTypeError, ApiValueError  # noqa: F401
  
  
  class QueuesV1Api(object):
      """NOTE: This class is auto generated by OpenAPI Generator
      Ref: https://openapi-generator.tech
  
      Do not edit the class manually.
      """
  
      def __init__(self, api_client=None):
          if api_client is None:
              api_client = ApiClient()
          self.api_client = api_client
  
      def create_queue(self, owner, agent, body, **kwargs):  # noqa: E501
          """Create queue  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.create_queue(owner, agent, body, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str agent: Agent that consumes the queue (required)
          :param V1Queue body: Queue body (required)
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: V1Queue
                   If the method is called asynchronously,
                   returns the request thread.
          """
          kwargs["_return_http_data_only"] = True
          return self.create_queue_with_http_info(
              owner, agent, body, **kwargs
          )  # noqa: E501
  
      def create_queue_with_http_info(self, owner, agent, body, **kwargs):  # noqa: E501
          """Create queue  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.create_queue_with_http_info(owner, agent, body, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str agent: Agent that consumes the queue (required)
          :param V1Queue body: Queue body (required)
          :param _return_http_data_only: response data without head status code
                                         and headers
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: tuple(V1Queue, status_code(int), headers(HTTPHeaderDict))
                   If the method is called asynchronously,
                   returns the request thread.
          """
  
          local_var_params = locals()
  
          all_params = ["owner", "agent", "body"]
          all_params.extend(
              [
                  "async_req",
                  "_return_http_data_only",
                  "_preload_content",
                  "_request_timeout",
              ]
          )
  
          for key, val in six.iteritems(local_var_params["kwargs"]):
              if key not in all_params:
                  raise ApiTypeError(
                      "Got an unexpected keyword argument '%s'"
                      " to method create_queue" % key
                  )
              local_var_params[key] = val
          del local_var_params["kwargs"]
          # verify the required parameter 'owner' is set
          if self.api_client.client_side_validation and (
              "owner" not in local_var_params
              or local_var_params["owner"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `owner` when calling `create_queue`"
              )  # noqa: E501
          # verify the required parameter 'agent' is set
          if self.api_client.client_side_validation and (
              "agent" not in local_var_params
              or local_var_params["agent"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `agent` when calling `create_queue`"
              )  # noqa: E501
          # verify the required parameter 'body' is set
          if self.api_client.client_side_validation and (
              "body" not in local_var_params
              or local_var_params["body"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `body` when calling `create_queue`"
              )  # noqa: E501
  
          collection_formats = {}
  
          path_params = {}
          if "owner" in local_var_params:
              path_params["owner"] = local_var_params["owner"]  # noqa: E501
          if "agent" in local_var_params:
              path_params["agent"] = local_var_params["agent"]  # noqa: E501
  
          query_params = []
  
          header_params = {}
  
          form_params = []
          local_var_files = {}
  
          body_params = None
          if "body" in local_var_params:
              body_params = local_var_params["body"]
          # HTTP header `Accept`
          header_params["Accept"] = self.api_client.select_header_accept(
              ["application/json"]
          )  # noqa: E501
  
          # HTTP header `Content-Type`
          header_params[
              "Content-Type"
          ] = self.api_client.select_header_content_type(  # noqa: E501
              ["application/json"]
          )  # noqa: E501
  
          # Authentication setting
          auth_settings = ["ApiKey"]  # noqa: E501
  
          return self.api_client.call_api(
              "/api/v1/orgs/{owner}/agents/{agent}/queues",
              "POST",
              path_params,
              query_params,
              header_params,
              body=body_params,
              post_params=form_params,
              files=local_var_files,
              response_type="V1Queue",  # noqa: E501
              auth_settings=auth_settings,
              async_req=local_var_params.get("async_req"),
              _return_http_data_only=local_var_params.get(
                  "_return_http_data_only"
              ),  # noqa: E501
              _preload_content=local_var_params.get("_preload_content", True),
              _request_timeout=local_var_params.get("_request_timeout"),
              collection_formats=collection_formats,
          )
  
      def delete_queue(self, owner, agent, uuid, **kwargs):  # noqa: E501
          """Delete queue  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.delete_queue(owner, agent, uuid, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str agent: Agent managing the resource (required)
          :param str uuid: Uuid identifier of the entity (required)
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: None
                   If the method is called asynchronously,
                   returns the request thread.
          """
          kwargs["_return_http_data_only"] = True
          return self.delete_queue_with_http_info(
              owner, agent, uuid, **kwargs
          )  # noqa: E501
  
      def delete_queue_with_http_info(self, owner, agent, uuid, **kwargs):  # noqa: E501
          """Delete queue  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.delete_queue_with_http_info(owner, agent, uuid, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str agent: Agent managing the resource (required)
          :param str uuid: Uuid identifier of the entity (required)
          :param _return_http_data_only: response data without head status code
                                         and headers
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: None
                   If the method is called asynchronously,
                   returns the request thread.
          """
  
          local_var_params = locals()
  
          all_params = ["owner", "agent", "uuid"]
          all_params.extend(
              [
                  "async_req",
                  "_return_http_data_only",
                  "_preload_content",
                  "_request_timeout",
              ]
          )
  
          for key, val in six.iteritems(local_var_params["kwargs"]):
              if key not in all_params:
                  raise ApiTypeError(
                      "Got an unexpected keyword argument '%s'"
                      " to method delete_queue" % key
                  )
              local_var_params[key] = val
          del local_var_params["kwargs"]
          # verify the required parameter 'owner' is set
          if self.api_client.client_side_validation and (
              "owner" not in local_var_params
              or local_var_params["owner"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `owner` when calling `delete_queue`"
              )  # noqa: E501
          # verify the required parameter 'agent' is set
          if self.api_client.client_side_validation and (
              "agent" not in local_var_params
              or local_var_params["agent"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `agent` when calling `delete_queue`"
              )  # noqa: E501
          # verify the required parameter 'uuid' is set
          if self.api_client.client_side_validation and (
              "uuid" not in local_var_params
              or local_var_params["uuid"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `uuid` when calling `delete_queue`"
              )  # noqa: E501
  
          collection_formats = {}
  
          path_params = {}
          if "owner" in local_var_params:
              path_params["owner"] = local_var_params["owner"]  # noqa: E501
          if "agent" in local_var_params:
              path_params["agent"] = local_var_params["agent"]  # noqa: E501
          if "uuid" in local_var_params:
              path_params["uuid"] = local_var_params["uuid"]  # noqa: E501
  
          query_params = []
  
          header_params = {}
  
          form_params = []
          local_var_files = {}
  
          body_params = None
          # HTTP header `Accept`
          header_params["Accept"] = self.api_client.select_header_accept(
              ["application/json"]
          )  # noqa: E501
  
          # Authentication setting
          auth_settings = ["ApiKey"]  # noqa: E501
  
          return self.api_client.call_api(
              "/api/v1/orgs/{owner}/agents/{agent}/queues/{uuid}",
              "DELETE",
              path_params,
              query_params,
              header_params,
              body=body_params,
              post_params=form_params,
              files=local_var_files,
              response_type=None,  # noqa: E501
              auth_settings=auth_settings,
              async_req=local_var_params.get("async_req"),
              _return_http_data_only=local_var_params.get(
                  "_return_http_data_only"
              ),  # noqa: E501
              _preload_content=local_var_params.get("_preload_content", True),
              _request_timeout=local_var_params.get("_request_timeout"),
              collection_formats=collection_formats,
          )
  
      def get_queue(self, owner, agent, uuid, **kwargs):  # noqa: E501
          """Get queue  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.get_queue(owner, agent, uuid, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str agent: Agent managing the resource (required)
          :param str uuid: Uuid identifier of the entity (required)
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: V1Queue
                   If the method is called asynchronously,
                   returns the request thread.
          """
          kwargs["_return_http_data_only"] = True
          return self.get_queue_with_http_info(owner, agent, uuid, **kwargs)  # noqa: E501
  
      def get_queue_with_http_info(self, owner, agent, uuid, **kwargs):  # noqa: E501
          """Get queue  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.get_queue_with_http_info(owner, agent, uuid, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str agent: Agent managing the resource (required)
          :param str uuid: Uuid identifier of the entity (required)
          :param _return_http_data_only: response data without head status code
                                         and headers
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: tuple(V1Queue, status_code(int), headers(HTTPHeaderDict))
                   If the method is called asynchronously,
                   returns the request thread.
          """
  
          local_var_params = locals()
  
          all_params = ["owner", "agent", "uuid"]
          all_params.extend(
              [
                  "async_req",
                  "_return_http_data_only",
                  "_preload_content",
                  "_request_timeout",
              ]
          )
  
          for key, val in six.iteritems(local_var_params["kwargs"]):
              if key not in all_params:
                  raise ApiTypeError(
                      "Got an unexpected keyword argument '%s'"
                      " to method get_queue" % key
                  )
              local_var_params[key] = val
          del local_var_params["kwargs"]
          # verify the required parameter 'owner' is set
          if self.api_client.client_side_validation and (
              "owner" not in local_var_params
              or local_var_params["owner"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `owner` when calling `get_queue`"
              )  # noqa: E501
          # verify the required parameter 'agent' is set
          if self.api_client.client_side_validation and (
              "agent" not in local_var_params
              or local_var_params["agent"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `agent` when calling `get_queue`"
              )  # noqa: E501
          # verify the required parameter 'uuid' is set
          if self.api_client.client_side_validation and (
              "uuid" not in local_var_params
              or local_var_params["uuid"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `uuid` when calling `get_queue`"
              )  # noqa: E501
  
          collection_formats = {}
  
          path_params = {}
          if "owner" in local_var_params:
              path_params["owner"] = local_var_params["owner"]  # noqa: E501
          if "agent" in local_var_params:
              path_params["agent"] = local_var_params["agent"]  # noqa: E501
          if "uuid" in local_var_params:
              path_params["uuid"] = local_var_params["uuid"]  # noqa: E501
  
          query_params = []
  
          header_params = {}
  
          form_params = []
          local_var_files = {}
  
          body_params = None
          # HTTP header `Accept`
          header_params["Accept"] = self.api_client.select_header_accept(
              ["application/json"]
          )  # noqa: E501
  
          # Authentication setting
          auth_settings = ["ApiKey"]  # noqa: E501
  
          return self.api_client.call_api(
              "/api/v1/orgs/{owner}/agents/{agent}/queues/{uuid}",
              "GET",
              path_params,
              query_params,
              header_params,
              body=body_params,
              post_params=form_params,
              files=local_var_files,
              response_type="V1Queue",  # noqa: E501
              auth_settings=auth_settings,
              async_req=local_var_params.get("async_req"),
              _return_http_data_only=local_var_params.get(
                  "_return_http_data_only"
              ),  # noqa: E501
              _preload_content=local_var_params.get("_preload_content", True),
              _request_timeout=local_var_params.get("_request_timeout"),
              collection_formats=collection_formats,
          )
  
      def list_organization_queue_names(self, owner, **kwargs):  # noqa: E501
          """List organization level queues names  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.list_organization_queue_names(owner, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param int offset: Pagination offset.
          :param int limit: Limit size.
          :param str sort: Sort to order the search.
          :param str query: Query filter the search search.
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: V1ListQueuesResponse
                   If the method is called asynchronously,
                   returns the request thread.
          """
          kwargs["_return_http_data_only"] = True
          return self.list_organization_queue_names_with_http_info(
              owner, **kwargs
          )  # noqa: E501
  
      def list_organization_queue_names_with_http_info(
          self, owner, **kwargs
      ):  # noqa: E501
          """List organization level queues names  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.list_organization_queue_names_with_http_info(owner, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param int offset: Pagination offset.
          :param int limit: Limit size.
          :param str sort: Sort to order the search.
          :param str query: Query filter the search search.
          :param _return_http_data_only: response data without head status code
                                         and headers
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: tuple(V1ListQueuesResponse, status_code(int), headers(HTTPHeaderDict))
                   If the method is called asynchronously,
                   returns the request thread.
          """
  
          local_var_params = locals()
  
          all_params = ["owner", "offset", "limit", "sort", "query"]
          all_params.extend(
              [
                  "async_req",
                  "_return_http_data_only",
                  "_preload_content",
                  "_request_timeout",
              ]
          )
  
          for key, val in six.iteritems(local_var_params["kwargs"]):
              if key not in all_params:
                  raise ApiTypeError(
                      "Got an unexpected keyword argument '%s'"
                      " to method list_organization_queue_names" % key
                  )
              local_var_params[key] = val
          del local_var_params["kwargs"]
          # verify the required parameter 'owner' is set
          if self.api_client.client_side_validation and (
              "owner" not in local_var_params
              or local_var_params["owner"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `owner` when calling `list_organization_queue_names`"
              )  # noqa: E501
  
          collection_formats = {}
  
          path_params = {}
          if "owner" in local_var_params:
              path_params["owner"] = local_var_params["owner"]  # noqa: E501
  
          query_params = []
          if (
              "offset" in local_var_params and local_var_params["offset"] is not None
          ):  # noqa: E501
              query_params.append(("offset", local_var_params["offset"]))  # noqa: E501
          if (
              "limit" in local_var_params and local_var_params["limit"] is not None
          ):  # noqa: E501
              query_params.append(("limit", local_var_params["limit"]))  # noqa: E501
          if (
              "sort" in local_var_params and local_var_params["sort"] is not None
          ):  # noqa: E501
              query_params.append(("sort", local_var_params["sort"]))  # noqa: E501
          if (
              "query" in local_var_params and local_var_params["query"] is not None
          ):  # noqa: E501
              query_params.append(("query", local_var_params["query"]))  # noqa: E501
  
          header_params = {}
  
          form_params = []
          local_var_files = {}
  
          body_params = None
          # HTTP header `Accept`
          header_params["Accept"] = self.api_client.select_header_accept(
              ["application/json"]
          )  # noqa: E501
  
          # Authentication setting
          auth_settings = ["ApiKey"]  # noqa: E501
  
          return self.api_client.call_api(
              "/api/v1/orgs/{owner}/queues/names",
              "GET",
              path_params,
              query_params,
              header_params,
              body=body_params,
              post_params=form_params,
              files=local_var_files,
              response_type="V1ListQueuesResponse",  # noqa: E501
              auth_settings=auth_settings,
              async_req=local_var_params.get("async_req"),
              _return_http_data_only=local_var_params.get(
                  "_return_http_data_only"
              ),  # noqa: E501
              _preload_content=local_var_params.get("_preload_content", True),
              _request_timeout=local_var_params.get("_request_timeout"),
              collection_formats=collection_formats,
          )
  
      def list_organization_queues(self, owner, **kwargs):  # noqa: E501
          """List organization level queues  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.list_organization_queues(owner, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param int offset: Pagination offset.
          :param int limit: Limit size.
          :param str sort: Sort to order the search.
          :param str query: Query filter the search search.
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: V1ListQueuesResponse
                   If the method is called asynchronously,
                   returns the request thread.
          """
          kwargs["_return_http_data_only"] = True
          return self.list_organization_queues_with_http_info(
              owner, **kwargs
          )  # noqa: E501
  
      def list_organization_queues_with_http_info(self, owner, **kwargs):  # noqa: E501
          """List organization level queues  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.list_organization_queues_with_http_info(owner, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param int offset: Pagination offset.
          :param int limit: Limit size.
          :param str sort: Sort to order the search.
          :param str query: Query filter the search search.
          :param _return_http_data_only: response data without head status code
                                         and headers
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: tuple(V1ListQueuesResponse, status_code(int), headers(HTTPHeaderDict))
                   If the method is called asynchronously,
                   returns the request thread.
          """
  
          local_var_params = locals()
  
          all_params = ["owner", "offset", "limit", "sort", "query"]
          all_params.extend(
              [
                  "async_req",
                  "_return_http_data_only",
                  "_preload_content",
                  "_request_timeout",
              ]
          )
  
          for key, val in six.iteritems(local_var_params["kwargs"]):
              if key not in all_params:
                  raise ApiTypeError(
                      "Got an unexpected keyword argument '%s'"
                      " to method list_organization_queues" % key
                  )
              local_var_params[key] = val
          del local_var_params["kwargs"]
          # verify the required parameter 'owner' is set
          if self.api_client.client_side_validation and (
              "owner" not in local_var_params
              or local_var_params["owner"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `owner` when calling `list_organization_queues`"
              )  # noqa: E501
  
          collection_formats = {}
  
          path_params = {}
          if "owner" in local_var_params:
              path_params["owner"] = local_var_params["owner"]  # noqa: E501
  
          query_params = []
          if (
              "offset" in local_var_params and local_var_params["offset"] is not None
          ):  # noqa: E501
              query_params.append(("offset", local_var_params["offset"]))  # noqa: E501
          if (
              "limit" in local_var_params and local_var_params["limit"] is not None
          ):  # noqa: E501
              query_params.append(("limit", local_var_params["limit"]))  # noqa: E501
          if (
              "sort" in local_var_params and local_var_params["sort"] is not None
          ):  # noqa: E501
              query_params.append(("sort", local_var_params["sort"]))  # noqa: E501
          if (
              "query" in local_var_params and local_var_params["query"] is not None
          ):  # noqa: E501
              query_params.append(("query", local_var_params["query"]))  # noqa: E501
  
          header_params = {}
  
          form_params = []
          local_var_files = {}
  
          body_params = None
          # HTTP header `Accept`
          header_params["Accept"] = self.api_client.select_header_accept(
              ["application/json"]
          )  # noqa: E501
  
          # Authentication setting
          auth_settings = ["ApiKey"]  # noqa: E501
  
          return self.api_client.call_api(
              "/api/v1/orgs/{owner}/queues",
              "GET",
              path_params,
              query_params,
              header_params,
              body=body_params,
              post_params=form_params,
              files=local_var_files,
              response_type="V1ListQueuesResponse",  # noqa: E501
              auth_settings=auth_settings,
              async_req=local_var_params.get("async_req"),
              _return_http_data_only=local_var_params.get(
                  "_return_http_data_only"
              ),  # noqa: E501
              _preload_content=local_var_params.get("_preload_content", True),
              _request_timeout=local_var_params.get("_request_timeout"),
              collection_formats=collection_formats,
          )
  
      def list_queue_names(self, owner, agent, **kwargs):  # noqa: E501
          """List queues names  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.list_queue_names(owner, agent, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str agent: Agent man managing the resource (required)
          :param int offset: Pagination offset.
          :param int limit: Limit size.
          :param str sort: Sort to order the search.
          :param str query: Query filter the search search.
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: V1ListQueuesResponse
                   If the method is called asynchronously,
                   returns the request thread.
          """
          kwargs["_return_http_data_only"] = True
          return self.list_queue_names_with_http_info(
              owner, agent, **kwargs
          )  # noqa: E501
  
      def list_queue_names_with_http_info(self, owner, agent, **kwargs):  # noqa: E501
          """List queues names  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.list_queue_names_with_http_info(owner, agent, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str agent: Agent man managing the resource (required)
          :param int offset: Pagination offset.
          :param int limit: Limit size.
          :param str sort: Sort to order the search.
          :param str query: Query filter the search search.
          :param _return_http_data_only: response data without head status code
                                         and headers
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: tuple(V1ListQueuesResponse, status_code(int), headers(HTTPHeaderDict))
                   If the method is called asynchronously,
                   returns the request thread.
          """
  
          local_var_params = locals()
  
          all_params = ["owner", "agent", "offset", "limit", "sort", "query"]
          all_params.extend(
              [
                  "async_req",
                  "_return_http_data_only",
                  "_preload_content",
                  "_request_timeout",
              ]
          )
  
          for key, val in six.iteritems(local_var_params["kwargs"]):
              if key not in all_params:
                  raise ApiTypeError(
                      "Got an unexpected keyword argument '%s'"
                      " to method list_queue_names" % key
                  )
              local_var_params[key] = val
          del local_var_params["kwargs"]
          # verify the required parameter 'owner' is set
          if self.api_client.client_side_validation and (
              "owner" not in local_var_params
              or local_var_params["owner"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `owner` when calling `list_queue_names`"
              )  # noqa: E501
          # verify the required parameter 'agent' is set
          if self.api_client.client_side_validation and (
              "agent" not in local_var_params
              or local_var_params["agent"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `agent` when calling `list_queue_names`"
              )  # noqa: E501
  
          collection_formats = {}
  
          path_params = {}
          if "owner" in local_var_params:
              path_params["owner"] = local_var_params["owner"]  # noqa: E501
          if "agent" in local_var_params:
              path_params["agent"] = local_var_params["agent"]  # noqa: E501
  
          query_params = []
          if (
              "offset" in local_var_params and local_var_params["offset"] is not None
          ):  # noqa: E501
              query_params.append(("offset", local_var_params["offset"]))  # noqa: E501
          if (
              "limit" in local_var_params and local_var_params["limit"] is not None
          ):  # noqa: E501
              query_params.append(("limit", local_var_params["limit"]))  # noqa: E501
          if (
              "sort" in local_var_params and local_var_params["sort"] is not None
          ):  # noqa: E501
              query_params.append(("sort", local_var_params["sort"]))  # noqa: E501
          if (
              "query" in local_var_params and local_var_params["query"] is not None
          ):  # noqa: E501
              query_params.append(("query", local_var_params["query"]))  # noqa: E501
  
          header_params = {}
  
          form_params = []
          local_var_files = {}
  
          body_params = None
          # HTTP header `Accept`
          header_params["Accept"] = self.api_client.select_header_accept(
              ["application/json"]
          )  # noqa: E501
  
          # Authentication setting
          auth_settings = ["ApiKey"]  # noqa: E501
  
          return self.api_client.call_api(
              "/api/v1/orgs/{owner}/agents/{agent}/queues/names",
              "GET",
              path_params,
              query_params,
              header_params,
              body=body_params,
              post_params=form_params,
              files=local_var_files,
              response_type="V1ListQueuesResponse",  # noqa: E501
              auth_settings=auth_settings,
              async_req=local_var_params.get("async_req"),
              _return_http_data_only=local_var_params.get(
                  "_return_http_data_only"
              ),  # noqa: E501
              _preload_content=local_var_params.get("_preload_content", True),
              _request_timeout=local_var_params.get("_request_timeout"),
              collection_formats=collection_formats,
          )
  
      def list_queues(self, owner, agent, **kwargs):  # noqa: E501
          """List queues  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.list_queues(owner, agent, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str agent: Agent man managing the resource (required)
          :param int offset: Pagination offset.
          :param int limit: Limit size.
          :param str sort: Sort to order the search.
          :param str query: Query filter the search search.
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: V1ListQueuesResponse
                   If the method is called asynchronously,
                   returns the request thread.
          """
          kwargs["_return_http_data_only"] = True
          return self.list_queues_with_http_info(owner, agent, **kwargs)  # noqa: E501
  
      def list_queues_with_http_info(self, owner, agent, **kwargs):  # noqa: E501
          """List queues  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.list_queues_with_http_info(owner, agent, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str agent: Agent man managing the resource (required)
          :param int offset: Pagination offset.
          :param int limit: Limit size.
          :param str sort: Sort to order the search.
          :param str query: Query filter the search search.
          :param _return_http_data_only: response data without head status code
                                         and headers
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: tuple(V1ListQueuesResponse, status_code(int), headers(HTTPHeaderDict))
                   If the method is called asynchronously,
                   returns the request thread.
          """
  
          local_var_params = locals()
  
          all_params = ["owner", "agent", "offset", "limit", "sort", "query"]
          all_params.extend(
              [
                  "async_req",
                  "_return_http_data_only",
                  "_preload_content",
                  "_request_timeout",
              ]
          )
  
          for key, val in six.iteritems(local_var_params["kwargs"]):
              if key not in all_params:
                  raise ApiTypeError(
                      "Got an unexpected keyword argument '%s'"
                      " to method list_queues" % key
                  )
              local_var_params[key] = val
          del local_var_params["kwargs"]
          # verify the required parameter 'owner' is set
          if self.api_client.client_side_validation and (
              "owner" not in local_var_params
              or local_var_params["owner"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `owner` when calling `list_queues`"
              )  # noqa: E501
          # verify the required parameter 'agent' is set
          if self.api_client.client_side_validation and (
              "agent" not in local_var_params
              or local_var_params["agent"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `agent` when calling `list_queues`"
              )  # noqa: E501
  
          collection_formats = {}
  
          path_params = {}
          if "owner" in local_var_params:
              path_params["owner"] = local_var_params["owner"]  # noqa: E501
          if "agent" in local_var_params:
              path_params["agent"] = local_var_params["agent"]  # noqa: E501
  
          query_params = []
          if (
              "offset" in local_var_params and local_var_params["offset"] is not None
          ):  # noqa: E501
              query_params.append(("offset", local_var_params["offset"]))  # noqa: E501
          if (
              "limit" in local_var_params and local_var_params["limit"] is not None
          ):  # noqa: E501
              query_params.append(("limit", local_var_params["limit"]))  # noqa: E501
          if (
              "sort" in local_var_params and local_var_params["sort"] is not None
          ):  # noqa: E501
              query_params.append(("sort", local_var_params["sort"]))  # noqa: E501
          if (
              "query" in local_var_params and local_var_params["query"] is not None
          ):  # noqa: E501
              query_params.append(("query", local_var_params["query"]))  # noqa: E501
  
          header_params = {}
  
          form_params = []
          local_var_files = {}
  
          body_params = None
          # HTTP header `Accept`
          header_params["Accept"] = self.api_client.select_header_accept(
              ["application/json"]
          )  # noqa: E501
  
          # Authentication setting
          auth_settings = ["ApiKey"]  # noqa: E501
  
          return self.api_client.call_api(
              "/api/v1/orgs/{owner}/agents/{agent}/queues",
              "GET",
              path_params,
              query_params,
              header_params,
              body=body_params,
              post_params=form_params,
              files=local_var_files,
              response_type="V1ListQueuesResponse",  # noqa: E501
              auth_settings=auth_settings,
              async_req=local_var_params.get("async_req"),
              _return_http_data_only=local_var_params.get(
                  "_return_http_data_only"
              ),  # noqa: E501
              _preload_content=local_var_params.get("_preload_content", True),
              _request_timeout=local_var_params.get("_request_timeout"),
              collection_formats=collection_formats,
          )
  
      def patch_queue(self, owner, queue_agent, queue_uuid, body, **kwargs):  # noqa: E501
          """Patch queue  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.patch_queue(owner, queue_agent, queue_uuid, body, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str queue_agent: Agent (required)
          :param str queue_uuid: UUID (required)
          :param V1Queue body: Queue body (required)
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: V1Queue
                   If the method is called asynchronously,
                   returns the request thread.
          """
          kwargs["_return_http_data_only"] = True
          return self.patch_queue_with_http_info(
              owner, queue_agent, queue_uuid, body, **kwargs
          )  # noqa: E501
  
      def patch_queue_with_http_info(
          self, owner, queue_agent, queue_uuid, body, **kwargs
      ):  # noqa: E501
          """Patch queue  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.patch_queue_with_http_info(owner, queue_agent, queue_uuid, body, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str queue_agent: Agent (required)
          :param str queue_uuid: UUID (required)
          :param V1Queue body: Queue body (required)
          :param _return_http_data_only: response data without head status code
                                         and headers
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: tuple(V1Queue, status_code(int), headers(HTTPHeaderDict))
                   If the method is called asynchronously,
                   returns the request thread.
          """
  
          local_var_params = locals()
  
          all_params = ["owner", "queue_agent", "queue_uuid", "body"]
          all_params.extend(
              [
                  "async_req",
                  "_return_http_data_only",
                  "_preload_content",
                  "_request_timeout",
              ]
          )
  
          for key, val in six.iteritems(local_var_params["kwargs"]):
              if key not in all_params:
                  raise ApiTypeError(
                      "Got an unexpected keyword argument '%s'"
                      " to method patch_queue" % key
                  )
              local_var_params[key] = val
          del local_var_params["kwargs"]
          # verify the required parameter 'owner' is set
          if self.api_client.client_side_validation and (
              "owner" not in local_var_params
              or local_var_params["owner"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `owner` when calling `patch_queue`"
              )  # noqa: E501
          # verify the required parameter 'queue_agent' is set
          if self.api_client.client_side_validation and (
              "queue_agent" not in local_var_params
              or local_var_params["queue_agent"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `queue_agent` when calling `patch_queue`"
              )  # noqa: E501
          # verify the required parameter 'queue_uuid' is set
          if self.api_client.client_side_validation and (
              "queue_uuid" not in local_var_params
              or local_var_params["queue_uuid"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `queue_uuid` when calling `patch_queue`"
              )  # noqa: E501
          # verify the required parameter 'body' is set
          if self.api_client.client_side_validation and (
              "body" not in local_var_params
              or local_var_params["body"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `body` when calling `patch_queue`"
              )  # noqa: E501
  
          collection_formats = {}
  
          path_params = {}
          if "owner" in local_var_params:
              path_params["owner"] = local_var_params["owner"]  # noqa: E501
          if "queue_agent" in local_var_params:
              path_params["queue.agent"] = local_var_params["queue_agent"]  # noqa: E501
          if "queue_uuid" in local_var_params:
              path_params["queue.uuid"] = local_var_params["queue_uuid"]  # noqa: E501
  
          query_params = []
  
          header_params = {}
  
          form_params = []
          local_var_files = {}
  
          body_params = None
          if "body" in local_var_params:
              body_params = local_var_params["body"]
          # HTTP header `Accept`
          header_params["Accept"] = self.api_client.select_header_accept(
              ["application/json"]
          )  # noqa: E501
  
          # HTTP header `Content-Type`
          header_params[
              "Content-Type"
          ] = self.api_client.select_header_content_type(  # noqa: E501
              ["application/json"]
          )  # noqa: E501
  
          # Authentication setting
          auth_settings = ["ApiKey"]  # noqa: E501
  
          return self.api_client.call_api(
              "/api/v1/orgs/{owner}/agents/{queue.agent}/queues/{queue.uuid}",
              "PATCH",
              path_params,
              query_params,
              header_params,
              body=body_params,
              post_params=form_params,
              files=local_var_files,
              response_type="V1Queue",  # noqa: E501
              auth_settings=auth_settings,
              async_req=local_var_params.get("async_req"),
              _return_http_data_only=local_var_params.get(
                  "_return_http_data_only"
              ),  # noqa: E501
              _preload_content=local_var_params.get("_preload_content", True),
              _request_timeout=local_var_params.get("_request_timeout"),
              collection_formats=collection_formats,
          )
  
      def update_queue(
          self, owner, queue_agent, queue_uuid, body, **kwargs
      ):  # noqa: E501
          """Update queue  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.update_queue(owner, queue_agent, queue_uuid, body, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str queue_agent: Agent (required)
          :param str queue_uuid: UUID (required)
          :param V1Queue body: Queue body (required)
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: V1Queue
                   If the method is called asynchronously,
                   returns the request thread.
          """
          kwargs["_return_http_data_only"] = True
          return self.update_queue_with_http_info(
              owner, queue_agent, queue_uuid, body, **kwargs
          )  # noqa: E501
  
      def update_queue_with_http_info(
          self, owner, queue_agent, queue_uuid, body, **kwargs
      ):  # noqa: E501
          """Update queue  # noqa: E501
  
          This method makes a synchronous HTTP request by default. To make an
          asynchronous HTTP request, please pass async_req=True
          >>> thread = api.update_queue_with_http_info(owner, queue_agent, queue_uuid, body, async_req=True)
          >>> result = thread.get()
  
          :param async_req bool: execute request asynchronously
          :param str owner: Owner of the namespace (required)
          :param str queue_agent: Agent (required)
          :param str queue_uuid: UUID (required)
          :param V1Queue body: Queue body (required)
          :param _return_http_data_only: response data without head status code
                                         and headers
          :param _preload_content: if False, the urllib3.HTTPResponse object will
                                   be returned without reading/decoding response
                                   data. Default is True.
          :param _request_timeout: timeout setting for this request. If one
                                   number provided, it will be total request
                                   timeout. It can also be a pair (tuple) of
                                   (connection, read) timeouts.
          :return: tuple(V1Queue, status_code(int), headers(HTTPHeaderDict))
                   If the method is called asynchronously,
                   returns the request thread.
          """
  
          local_var_params = locals()
  
          all_params = ["owner", "queue_agent", "queue_uuid", "body"]
          all_params.extend(
              [
                  "async_req",
                  "_return_http_data_only",
                  "_preload_content",
                  "_request_timeout",
              ]
          )
  
          for key, val in six.iteritems(local_var_params["kwargs"]):
              if key not in all_params:
                  raise ApiTypeError(
                      "Got an unexpected keyword argument '%s'"
                      " to method update_queue" % key
                  )
              local_var_params[key] = val
          del local_var_params["kwargs"]
          # verify the required parameter 'owner' is set
          if self.api_client.client_side_validation and (
              "owner" not in local_var_params
              or local_var_params["owner"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `owner` when calling `update_queue`"
              )  # noqa: E501
          # verify the required parameter 'queue_agent' is set
          if self.api_client.client_side_validation and (
              "queue_agent" not in local_var_params
              or local_var_params["queue_agent"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `queue_agent` when calling `update_queue`"
              )  # noqa: E501
          # verify the required parameter 'queue_uuid' is set
          if self.api_client.client_side_validation and (
              "queue_uuid" not in local_var_params
              or local_var_params["queue_uuid"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `queue_uuid` when calling `update_queue`"
              )  # noqa: E501
          # verify the required parameter 'body' is set
          if self.api_client.client_side_validation and (
              "body" not in local_var_params
              or local_var_params["body"] is None  # noqa: E501
          ):  # noqa: E501
              raise ApiValueError(
                  "Missing the required parameter `body` when calling `update_queue`"
              )  # noqa: E501
  
          collection_formats = {}
  
          path_params = {}
          if "owner" in local_var_params:
              path_params["owner"] = local_var_params["owner"]  # noqa: E501
          if "queue_agent" in local_var_params:
              path_params["queue.agent"] = local_var_params["queue_agent"]  # noqa: E501
          if "queue_uuid" in local_var_params:
              path_params["queue.uuid"] = local_var_params["queue_uuid"]  # noqa: E501
  
          query_params = []
  
          header_params = {}
  
          form_params = []
          local_var_files = {}
  
          body_params = None
          if "body" in local_var_params:
              body_params = local_var_params["body"]
          # HTTP header `Accept`
          header_params["Accept"] = self.api_client.select_header_accept(
              ["application/json"]
          )  # noqa: E501
  
          # HTTP header `Content-Type`
          header_params[
              "Content-Type"
          ] = self.api_client.select_header_content_type(  # noqa: E501
              ["application/json"]
          )  # noqa: E501
  
          # Authentication setting
          auth_settings = ["ApiKey"]  # noqa: E501
  
          return self.api_client.call_api(
              "/api/v1/orgs/{owner}/agents/{queue.agent}/queues/{queue.uuid}",
              "PUT",
              path_params,
              query_params,
              header_params,
              body=body_params,
              post_params=form_params,
              files=local_var_files,
              response_type="V1Queue",  # noqa: E501
              auth_settings=auth_settings,
              async_req=local_var_params.get("async_req"),
              _return_http_data_only=local_var_params.get(
                  "_return_http_data_only"
              ),  # noqa: E501
              _preload_content=local_var_params.get("_preload_content", True),
              _request_timeout=local_var_params.get("_request_timeout"),
              collection_formats=collection_formats,
          )
  