celery__celery-9465

{
  "status": "ok",
  "stdout": "99:        self.port = port or conf.get('cassandra_port', None)\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "celery/backends/cassandra.py",
  "content": "\n    #: List of Cassandra servers with format: ``hostname``.\n    servers = None\n    #: Location of the secure connect bundle zipfile (absolute path).\n    bundle_path = None\n\n    supports_autoexpire = True      # autoexpire supported via entry_ttl\n\n    def __init__(self, servers=None, keyspace=None, table=None, entry_ttl=None,\n                 port=9042, bundle_path=None, **kwargs):\n        super().__init__(**kwargs)\n\n        if not cassandra:\n            raise ImproperlyConfigured(E_NO_CASSANDRA)\n\n        conf = self.app.conf\n        self.servers = servers or conf.get('cassandra_servers', None)\n        self.bundle_path = bundle_path or conf.get(\n            'cassandra_secure_bundle_path', None)\n        self.port = port or conf.get('cassandra_port', None)\n        self.keyspace = keyspace or conf.get('cassandra_keyspace', None)\n        self.table = table or conf.get('cassandra_table', None)\n        self.cassandra_options = conf.get('cassandra_options', {})\n\n        # either servers or bundle path must be provided...\n        db_directions = self.servers or self.bundle_path\n        if not db_directions or not self.keyspace or not self.table:\n            raise ImproperlyConfigured(E_CASSANDRA_NOT_CONFIGURED)\n        # ...but not both:\n        if self.servers and self.bundle_path:\n            raise ImproperlyConfigured(E_CASSANDRA_MISCONFIGURED)\n\n        expires = entry_ttl or conf.get('cassandra_entry_ttl', None)\n\n        self.cqlexpires = (\n            Q_EXPIRES.format(expires) if expires is not None else '')\n\n        read_cons = conf.get('cassandra_read_consistency') or 'LOCAL_QUORUM'\n        write_cons = conf.get('cassandra_write_consistency') or 'LOCAL_QUORUM'\n\n        self.read_consistency = getattr(",
  "start_line": 80,
  "end_line": 120,
  "total_lines": 256,
  "is_truncated": false
}

{
  "status": "ok",
  "stdout": "99:        self.port = port or conf.get('cassandra_port', None)\n157:                    self.servers, port=self.port,\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "celery/backends/cassandra.py",
  "content": "        self._lock.acquire()\n        try:\n            if self._session is not None:\n                return\n            # using either 'servers' or 'bundle_path' here:\n            if self.servers:\n                self._cluster = cassandra.cluster.Cluster(\n                    self.servers, port=self.port,\n                    auth_provider=self.auth_provider,\n                    **self.cassandra_options)\n            else:\n                # 'bundle_path' is guaranteed to be set\n                self._cluster = cassandra.cluster.Cluster(\n                    cloud={\n                        'secure_connect_bundle': self.bundle_path,\n                    },\n                    auth_provider=self.auth_provider,\n                    **self.cassandra_options)\n            self._session = self._cluster.connect(self.keyspace)\n\n            # We're forced to do concatenation below, as formatting would",
  "start_line": 150,
  "end_line": 170,
  "total_lines": 256,
  "is_truncated": false
}

{
  "status": "ok",
  "stdout": "t/unit/backends/test_cassandra.py:19:class test_CassandraBackend:\nt/unit/backends/test_cassandra.py:36:                mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:52:        mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:54:        mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:60:            mod.CassandraBackend(\nt/unit/backends/test_cassandra.py:69:            mod.CassandraBackend(\nt/unit/backends/test_cassandra.py:96:        x = mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:103:        from celery.backends.cassandra import CassandraBackend\nt/unit/backends/test_cassandra.py:104:        assert loads(dumps(CassandraBackend(app=self.app)))\nt/unit/backends/test_cassandra.py:111:        x = mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:133:        x = mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:142:        x = mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:170:        x = mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:205:        x = mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:225:        x = mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:250:        mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:258:            mod.CassandraBackend(app=self.app)\nt/unit/backends/test_cassandra.py:270:        mod.CassandraBackend(app=self.app)\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "t/unit/backends/test_cassandra.py",
  "content": "from datetime import datetime\nfrom pickle import dumps, loads\nfrom unittest.mock import Mock\n\nimport pytest\n\nfrom celery import states\nfrom celery.exceptions import ImproperlyConfigured\nfrom celery.utils.objects import Bunch\n\nCASSANDRA_MODULES = [\n    'cassandra',\n    'cassandra.auth',\n    'cassandra.cluster',\n    'cassandra.query',\n]\n\n\nclass test_CassandraBackend:\n\n    def setup_method(self):\n        self.app.conf.update(\n            cassandra_servers=['example.com'],\n            cassandra_keyspace='celery',\n            cassandra_table='task_results',\n        )\n\n    @pytest.mark.patched_module(*CASSANDRA_MODULES)\n    def test_init_no_cassandra(self, module):\n        # should raise ImproperlyConfigured when no python-driver\n        # installed.\n        from celery.backends import cassandra as mod\n        prev, mod.cassandra = mod.cassandra, None\n        try:\n            with pytest.raises(ImproperlyConfigured):\n                mod.CassandraBackend(app=self.app)\n        finally:\n            mod.cassandra = prev\n\n    @pytest.mark.patched_module(*CASSANDRA_MODULES)\n    def test_init_with_and_without_LOCAL_QUROM(self, module):\n        from celery.backends import cassandra as mod\n        mod.cassandra = Mock()\n\n        cons = mod.cassandra.ConsistencyLevel = Bunch(\n            LOCAL_QUORUM='foo',\n        )\n\n        self.app.conf.cassandra_read_consistency = 'LOCAL_FOO'\n        self.app.conf.cassandra_write_consistency = 'LOCAL_FOO'\n\n        mod.CassandraBackend(app=self.app)\n        cons.LOCAL_FOO = 'bar'\n        mod.CassandraBackend(app=self.app)\n\n        # no servers and no bundle_path raises ImproperlyConfigured\n        with pytest.raises(ImproperlyConfigured):\n            self.app.conf.cassandra_servers = None\n            self.app.conf.cassandra_secure_bundle_path = None\n            mod.CassandraBackend(\n                app=self.app, keyspace='b', column_family='c',\n            )\n\n        # both servers no bundle_path raises ImproperlyConfigured\n        with pytest.raises(ImproperlyConfigured):\n            self.app.conf.cassandra_servers = ['localhost']\n            self.app.conf.cassandra_secure_bundle_path = (\n                '/home/user/secure-connect-bundle.zip')\n            mod.CassandraBackend(\n                app=self.app, keyspace='b', column_family='c',\n            )\n\n    def test_init_with_cloud(self):\n        # Tests behavior when Cluster.connect works properly\n        # and cluster is created with 'cloud' param instead of 'contact_points'\n        from celery.backends import cassandra as mod\n\n        class DummyClusterWithBundle:\n\n            def __init__(self, *args, **kwargs):\n                if args != ():\n                    # this cluster is supposed to be created with 'cloud=...'\n                    raise ValueError('I should be created with kwargs only')\n                pass\n\n            def connect(self, *args, **kwargs):\n                return Mock()\n\n        mod.cassandra = Mock()\n        mod.cassandra.cluster = Mock()\n        mod.cassandra.cluster.Cluster = DummyClusterWithBundle\n\n        self.app.conf.cassandra_secure_bundle_path = '/path/to/bundle.zip'\n        self.app.conf.cassandra_servers = None\n\n        x = mod.CassandraBackend(app=self.app)\n        x._get_connection()\n        assert isinstance(x._cluster, DummyClusterWithBundle)\n\n    @pytest.mark.patched_module(*CASSANDRA_MODULES)\n    @pytest.mark.usefixtures('depends_on_current_app')\n    def test_reduce(self, module):\n        from celery.backends.cassandra import CassandraBackend\n        assert loads(dumps(CassandraBackend(app=self.app)))\n\n    @pytest.mark.patched_module(*CASSANDRA_MODULES)\n    def test_get_task_meta_for(self, module):\n        from celery.backends import cassandra as mod\n        mod.cassandra = Mock()\n\n        x = mod.CassandraBackend(app=self.app)\n        session = x._session = Mock()\n        execute = session.execute = Mock()\n        result_set = Mock()\n        result_set.one.return_value = [\n            states.SUCCESS, '1', datetime.now(), b'', b''\n        ]\n        execute.return_value = result_set\n        x.decode = Mock()\n        meta = x._get_task_meta_for('task_id')\n        assert meta['status'] == states.SUCCESS\n\n        result_set.one.return_value = []\n        x._session.execute.return_value = result_set\n        meta = x._get_task_meta_for('task_id')\n        assert meta['status'] == states.PENDING\n\n    def test_as_uri(self):\n        # Just ensure as_uri works properly\n        from celery.backends import cassandra as mod\n        mod.cassandra = Mock()\n\n        x = mod.CassandraBackend(app=self.app)\n        x.as_uri()\n        x.as_uri(include_password=False)\n\n    @pytest.mark.patched_module(*CASSANDRA_MODULES)\n    def test_store_result(self, module):\n        from celery.backends import cassandra as mod\n        mod.cassandra = Mock()\n\n        x = mod.CassandraBackend(app=self.app)\n        session = x._session = Mock()\n        session.execute = Mock()\n        x._store_result('task_id', 'result', states.SUCCESS)\n\n    def test_timeouting_cluster(self):\n        # Tests behavior when Cluster.connect raises\n        # cassandra.OperationTimedOut.\n        from celery.backends import cassandra as mod",
  "start_line": 1,
  "end_line": 150,
  "total_lines": 270,
  "is_truncated": true
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "Traceback (most recent call last):\n  File \"<stdin>\", line 34, in <module>\n  File \"<stdin>\", line 9, in test_cassandra_port_config\nTypeError: Bunch.__init__() takes 1 positional argument but 2 were given\n",
  "details": {
    "stdout": "Test failed: Bunch.__init__() takes 1 positional argument but 2 were given\n",
    "stderr": "Traceback (most recent call last):\n  File \"<stdin>\", line 34, in <module>\n  File \"<stdin>\", line 9, in test_cassandra_port_config\nTypeError: Bunch.__init__() takes 1 positional argument but 2 were given\n",
    "exit_code": 1
  }
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "Traceback (most recent call last):\n  File \"<stdin>\", line 38, in <module>\n  File \"<stdin>\", line 25, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 90, in __init__\n    super().__init__(**kwargs)\n  File \"/workspace/celery/backends/base.py\", line 116, in __init__\n    self.serializer = serializer or conf.result_serializer\nAttributeError: 'SimpleConf' object has no attribute 'result_serializer'\n",
  "details": {
    "stdout": "Test failed: 'SimpleConf' object has no attribute 'result_serializer'\n",
    "stderr": "Traceback (most recent call last):\n  File \"<stdin>\", line 38, in <module>\n  File \"<stdin>\", line 25, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 90, in __init__\n    super().__init__(**kwargs)\n  File \"/workspace/celery/backends/base.py\", line 116, in __init__\n    self.serializer = serializer or conf.result_serializer\nAttributeError: 'SimpleConf' object has no attribute 'result_serializer'\n",
    "exit_code": 1
  }
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "Traceback (most recent call last):\n  File \"<stdin>\", line 39, in <module>\n  File \"<stdin>\", line 27, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 90, in __init__\n    super().__init__(**kwargs)\n  File \"/workspace/celery/backends/base.py\", line 128, in __init__\n    self.accept = prepare_accept_content(self.accept)\n  File \"/usr/local/lib/python3.10/site-packages/kombu/serialization.py\", line 459, in prepare_accept_content\n    return {n if '/' in n else name_to_type[n] for n in content_types}\nTypeError: 'Mock' object is not iterable\n",
  "details": {
    "stdout": "Test failed: 'Mock' object is not iterable\n",
    "stderr": "Traceback (most recent call last):\n  File \"<stdin>\", line 39, in <module>\n  File \"<stdin>\", line 27, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 90, in __init__\n    super().__init__(**kwargs)\n  File \"/workspace/celery/backends/base.py\", line 128, in __init__\n    self.accept = prepare_accept_content(self.accept)\n  File \"/usr/local/lib/python3.10/site-packages/kombu/serialization.py\", line 459, in prepare_accept_content\n    return {n if '/' in n else name_to_type[n] for n in content_types}\nTypeError: 'Mock' object is not iterable\n",
    "exit_code": 1
  }
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "Traceback (most recent call last):\n  File \"<stdin>\", line 43, in <module>\n  File \"<stdin>\", line 31, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 90, in __init__\n    super().__init__(**kwargs)\n  File \"/workspace/celery/backends/base.py\", line 128, in __init__\n    self.accept = prepare_accept_content(self.accept)\n  File \"/usr/local/lib/python3.10/site-packages/kombu/serialization.py\", line 459, in prepare_accept_content\n    return {n if '/' in n else name_to_type[n] for n in content_types}\nTypeError: 'Mock' object is not iterable\n",
  "details": {
    "stdout": "Test failed: 'Mock' object is not iterable\n",
    "stderr": "Traceback (most recent call last):\n  File \"<stdin>\", line 43, in <module>\n  File \"<stdin>\", line 31, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 90, in __init__\n    super().__init__(**kwargs)\n  File \"/workspace/celery/backends/base.py\", line 128, in __init__\n    self.accept = prepare_accept_content(self.accept)\n  File \"/usr/local/lib/python3.10/site-packages/kombu/serialization.py\", line 459, in prepare_accept_content\n    return {n if '/' in n else name_to_type[n] for n in content_types}\nTypeError: 'Mock' object is not iterable\n",
    "exit_code": 1
  }
}

{
  "status": "ok",
  "filepath": "celery/backends/base.py",
  "content": "\n    def __init__(self, app,\n                 serializer=None, max_cached_results=None, accept=None,\n                 expires=None, expires_type=None, url=None, **kwargs):\n        self.app = app\n        conf = self.app.conf\n        self.serializer = serializer or conf.result_serializer\n        (self.content_type,\n         self.content_encoding,\n         self.encoder) = serializer_registry._encoders[self.serializer]\n        cmax = max_cached_results or conf.result_cache_max\n        self._cache = _nulldict() if cmax == -1 else LRUCache(limit=cmax)\n\n        self.expires = self.prepare_expires(expires, expires_type)\n\n        # precedence: accept, conf.result_accept_content, conf.accept_content\n        self.accept = conf.result_accept_content if accept is None else accept\n        self.accept = conf.accept_content if self.accept is None else self.accept\n        self.accept = prepare_accept_content(self.accept)\n\n        self.always_retry = conf.get('result_backend_always_retry', False)\n        self.max_sleep_between_retries_ms = conf.get('result_backend_max_sleep_between_retries_ms', 10000)\n        self.base_sleep_between_retries_ms = conf.get('result_backend_base_sleep_between_retries_ms', 10)\n        self.max_retries = conf.get('result_backend_max_retries', float(\"inf\"))\n        self.thread_safe = conf.get('result_backend_thread_safe', False)\n\n        self._pending_results = pending_results_t({}, WeakValueDictionary())\n        self._pending_messages = BufferMap(MESSAGE_BUFFER_MAX)\n        self.url = url\n\n    def as_uri(self, include_password=False):",
  "start_line": 110,
  "end_line": 140,
  "total_lines": 1112,
  "is_truncated": false
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "Traceback (most recent call last):\n  File \"<stdin>\", line 38, in <module>\n  File \"<stdin>\", line 26, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 95, in __init__\n    conf = self.app.conf\nAttributeError: 'CassandraBackend' object has no attribute 'app'\n",
  "details": {
    "stdout": "Test failed: 'CassandraBackend' object has no attribute 'app'\n",
    "stderr": "Traceback (most recent call last):\n  File \"<stdin>\", line 38, in <module>\n  File \"<stdin>\", line 26, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 95, in __init__\n    conf = self.app.conf\nAttributeError: 'CassandraBackend' object has no attribute 'app'\n",
    "exit_code": 1
  }
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "Traceback (most recent call last):\n  File \"<stdin>\", line 47, in <module>\n  File \"<stdin>\", line 35, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 90, in __init__\n    super().__init__(**kwargs)\n  File \"/workspace/celery/backends/base.py\", line 123, in __init__\n    self.expires = self.prepare_expires(expires, expires_type)\n  File \"/workspace/celery/backends/base.py\", line 438, in prepare_expires\n    value = self.app.conf.result_expires\nAttributeError: 'Conf' object has no attribute 'result_expires'\n",
  "details": {
    "stdout": "Test failed: 'Conf' object has no attribute 'result_expires'\n",
    "stderr": "Traceback (most recent call last):\n  File \"<stdin>\", line 47, in <module>\n  File \"<stdin>\", line 35, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 90, in __init__\n    super().__init__(**kwargs)\n  File \"/workspace/celery/backends/base.py\", line 123, in __init__\n    self.expires = self.prepare_expires(expires, expires_type)\n  File \"/workspace/celery/backends/base.py\", line 438, in prepare_expires\n    value = self.app.conf.result_expires\nAttributeError: 'Conf' object has no attribute 'result_expires'\n",
    "exit_code": 1
  }
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "Traceback (most recent call last):\n  File \"<stdin>\", line 38, in <module>\n  File \"<stdin>\", line 26, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 95, in __init__\n    conf = self.app.conf\nAttributeError: 'CassandraBackend' object has no attribute 'app'\n",
  "details": {
    "stdout": "Test failed: 'CassandraBackend' object has no attribute 'app'\n",
    "stderr": "Traceback (most recent call last):\n  File \"<stdin>\", line 38, in <module>\n  File \"<stdin>\", line 26, in test_cassandra_port_config\n  File \"/workspace/celery/backends/cassandra.py\", line 95, in __init__\n    conf = self.app.conf\nAttributeError: 'CassandraBackend' object has no attribute 'app'\n",
    "exit_code": 1
  }
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "Traceback (most recent call last):\n  File \"<stdin>\", line 48, in <module>\n  File \"<stdin>\", line 44, in test_cassandra_port_config\nAssertionError: Expected port='61003', got 9042\n",
  "details": {
    "stdout": "Test failed: Expected port='61003', got 9042\n",
    "stderr": "Traceback (most recent call last):\n  File \"<stdin>\", line 48, in <module>\n  File \"<stdin>\", line 44, in test_cassandra_port_config\nAssertionError: Expected port='61003', got 9042\n",
    "exit_code": 1
  }
}