ARCHIVED TRAINING / celery/celery
celery__celery-9465
This is a preserved training example. Membership in the current training wave has not been verified.
Problem statement
Config cassandra backend port config not work
## Checklist
- [ ] I have included the output of ``celery -A proj report`` in the issue.
(if you are not able to do this, then at least specify the Celery
version affected).
```
software -> celery:4.1.0 (latentcall) kombu:4.1.0 py:2.7.12
billiard:3.5.0.3 py-amqp:2.2.2
platform -> system:Linux arch:64bit, ELF imp:CPython
loader -> celery.loaders.app.AppLoader
settings -> transport:amqp results:cassandra
broker_url: u'amqp://guest:********@localhost:32781//'
cassandra_entry_ttl: 86400
cassandra_table: 'tasks_result'
cassandra_port: '61003'
cassandra_write_consistency: 'ONE'
cassandra_read_consistency: 'ONE'
include: [u'celery_for_medium.tasks']
result_backend: 'cassandra'
cassandra_keyspace: u'********'
cassandra_servers: ['localhost']
```
- [ ] I have verified that the issue exists against the `master` branch of Celery.
## Steps to reproduce
## Expected behavior
Result data should write correctly to cassandra database at: **localhost:61003**
## Actual behavior
```
[2018-12-07 14:28:17,815: ERROR/ForkPoolWorker-1] Control connection failed to connect, shutting down Cluster:
Traceback (most recent call last):
File "cassandra/cluster.py", line 1301, in cassandra.cluster.Cluster.connect
self.control_connection.connect()
File "cassandra/cluster.py", line 2802, in cassandra.cluster.ControlConnection.connect
self._set_new_connection(self._reconnect_internal())
File "cassandra/cluster.py", line 2845, in cassandra.cluster.ControlConnection._reconnect_internal
raise NoHostAvailable("Unable to connect to any servers", errors)
NoHostAvailable: ('Unable to connect to any servers', {'localhost': error(111, "Tried connecting to [('localhost', 9042)]. Last error: Connection refused")})
```
Training membership
opd_e4b_cispo_v5 opd_e4b_pure_v6a opd_e4b_pure_v6b opd_e4b_pure_v7 opd_e4b_pure_v7b
Task issues extracted from preserved verified_rft_messages training examples. This is not a verified current RL wave manifest.
Task and snapshot provenance
Snapshot captured 2026-11-12T17:06:59.476467+00:00 · Autoresearch-Arena/gemma-4-developer-agent
{
"datasets": [
"opd_e4b_cispo_v5",
"opd_e4b_pure_v6a",
"opd_e4b_pure_v6b",
"opd_e4b_pure_v7",
"opd_e4b_pure_v7b"
],
"examples": 17,
"instance_id": "celery__celery-9465",
"problem_statement": "Config cassandra backend port config not work\n## Checklist\r\n\r\n- [ ] I have included the output of ``celery -A proj report`` in the issue.\r\n (if you are not able to do this, then at least specify the Celery\r\n version affected).\r\n```\r\nsoftware -> celery:4.1.0 (latentcall) kombu:4.1.0 py:2.7.12\r\n billiard:3.5.0.3 py-amqp:2.2.2\r\nplatform -> system:Linux arch:64bit, ELF imp:CPython\r\nloader -> celery.loaders.app.AppLoader\r\nsettings -> transport:amqp results:cassandra\r\n\r\nbroker_url: u'amqp://guest:********@localhost:32781//'\r\ncassandra_entry_ttl: 86400\r\ncassandra_table: 'tasks_result'\r\ncassandra_port: '61003'\r\ncassandra_write_consistency: 'ONE'\r\ncassandra_read_consistency: 'ONE'\r\ninclude: [u'celery_for_medium.tasks']\r\nresult_backend: 'cassandra'\r\ncassandra_keyspace: u'********'\r\ncassandra_servers: ['localhost']\r\n```\r\n- [ ] I have verified that the issue exists against the `master` branch of Celery.\r\n\r\n## Steps to reproduce\r\n\r\n## Expected behavior\r\nResult data should write correctly to cassandra database at: **localhost:61003**\r\n## Actual behavior\r\n```\r\n[2018-12-07 14:28:17,815: ERROR/ForkPoolWorker-1] Control connection failed to connect, shutting down Cluster:\r\nTraceback (most recent call last):\r\n File \"cassandra/cluster.py\", line 1301, in cassandra.cluster.Cluster.connect\r\n self.control_connection.connect()\r\n File \"cassandra/cluster.py\", line 2802, in cassandra.cluster.ControlConnection.connect\r\n self._set_new_connection(self._reconnect_internal())\r\n File \"cassandra/cluster.py\", line 2845, in cassandra.cluster.ControlConnection._reconnect_internal\r\n raise NoHostAvailable(\"Unable to connect to any servers\", errors)\r\nNoHostAvailable: ('Unable to connect to any servers', {'localhost': error(111, \"Tried connecting to [('localhost', 9042)]. Last error: Connection refused\")})\r\n```",
"repo": "celery/celery",
"source": "v2/experiments/train_data/opd_e4b_cispo_v5/verified_rft_messages.jsonl",
"source_sha256": "a43610ad0dfb6ace95375cfae09000f41afc0338cc925af870a4ade7a9b20c4c"
}{
"captured_at": "2026-11-12T17:06:59.476467+00:00",
"membership": "archived training",
"membership_evidence": "Task issues extracted from preserved verified_rft_messages training examples. This is not a verified current RL wave manifest.",
"name": "Preserved post-training task archive",
"source": "Autoresearch-Arena/gemma-4-developer-agent",
"source_revision": "016496de222aaafca0d4ee4c18efc63ba616f76e",
"sources": [
{
"path": "v2/experiments/train_data/opd_e4b_cispo_v5/verified_rft_messages.jsonl",
"sha256": "a43610ad0dfb6ace95375cfae09000f41afc0338cc925af870a4ade7a9b20c4c"
},
{
"path": "v2/experiments/train_data/opd_e4b_hybrid_v3/verified_rft_messages.jsonl",
"sha256": "bd326303eb127e8e5e08f03daf97bb88d79d19709d59f3f93f348bc56686a8df"
},
{
"path": "v2/experiments/train_data/opd_e4b_onpolicy_v3/verified_rft_messages.jsonl",
"sha256": "960c680e797e823a0d3a22f4b1d5ef60a72971373d703b877340b0c9126aaf68"
},
{
"path": "v2/experiments/train_data/opd_e4b_pure_v6a/verified_rft_messages.jsonl",
"sha256": "f045b7ca5b3883a1e2eaee81e1c02a4a1b53dd7b7b36e98bacb2ba5823a15148"
},
{
"path": "v2/experiments/train_data/opd_e4b_pure_v6b/verified_rft_messages.jsonl",
"sha256": "0f62460a9706eea5e1605255896f191ab00cb5706c5f1f2e1c293e9a718218dc"
},
{
"path": "v2/experiments/train_data/opd_e4b_pure_v7/verified_rft_messages.jsonl",
"sha256": "e37f7bd675322f3f81500b73559d60d5f602ca0537bf19f5cb06332c728c7b72"
},
{
"path": "v2/experiments/train_data/opd_e4b_pure_v7b/verified_rft_messages.jsonl",
"sha256": "b864bdc8695183433eef6e31cb8d33fad44ba3aded2170c1ade4ad5b2944ce23"
},
{
"path": "v2/experiments/train_data/opd_e4b_self_audit_v4/verified_rft_messages.jsonl",
"sha256": "0026023745afb8f3dc1c176dc7f7171157b4ad5a66656b524af218e8e19ceee6"
},
{
"path": "v2/experiments/train_data/rft_e4b_aligned_v2/verified_rft_messages.jsonl",
"sha256": "92a4515fee9d152b0d4c510ee3ce4caaaffe2003ba7584469f8027f174aab18c"
},
{
"path": "v2/experiments/train_data/rft_v1/verified_rft_messages.jsonl",
"sha256": "a42453ccd7ac7680b0a03865e8e7080bc8bf74c8d9d193b440c441ed46f8512b"
},
{
"path": "v2/experiments/train_data/rft_v2/verified_rft_messages.jsonl",
"sha256": "18f4b3bd7e651f83c6acab479c9475e3fa50dc652a384f309e97146983ac85ba"
}
]
}