def __init__()

in common/cloud_task/cloud_task_publisher.py [0:0]

• 12 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(self, project: str, location: str, queue: str, max_rps: int = 60):
        """
        Initializes the CloudTaskPublisher with the necessary configuration.
        """
        self.project = project
        self.location = location
        self.queue_name = queue
        self.max_rps = max_rps
        self._wait_after_queue_creation = 30
        self._cloud_task_client = tasks.CloudTasksClient()
        self._resource_manager_client = ResourceManagerApiAdapter()
        self._queue_fqn = self._cloud_task_client.queue_path(
            self.project, self.location, self.queue_name
        )
        self._logger = get_logger()