Untitled

[2025-03-27, 10:14:28 UTC] {local_task_job_runner.py:123} ▶ Pre task execution logs
[2025-03-27, 10:14:28 UTC] {cassandra_client.py:58} ERROR - Error connecting to Cassandra: {}
[2025-03-27, 10:14:28 UTC] {taskinstance.py:3313} ERROR - Task failed with exception
Traceback (most recent call last):
  File "/home/airflow/.local/lib/python3.12/site-packages/airflow/models/taskinstance.py", line 768, in _execute_task
    result = _execute_callable(context=context, **execute_callable_kwargs)
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/airflow/.local/lib/python3.12/site-packages/airflow/models/taskinstance.py", line 734, in _execute_callable
    return ExecutionCallableRunner(
           ^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/airflow/.local/lib/python3.12/site-packages/airflow/utils/operator_helpers.py", line 252, in run
    return self.func(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/airflow/.local/lib/python3.12/site-packages/airflow/models/baseoperator.py", line 424, in wrapper
    return func(self, *args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/airflow/.local/lib/python3.12/site-packages/airflow/operators/python.py", line 238, in execute
    return_value = self.execute_callable()
                   ^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/airflow/.local/lib/python3.12/site-packages/airflow/operators/python.py", line 256, in execute_callable
    return runner.run(*self.op_args, **self.op_kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/airflow/.local/lib/python3.12/site-packages/airflow/utils/operator_helpers.py", line 252, in run
    return self.func(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/airflow/dags/scraper_dag.py", line 96, in <lambda>
    python_callable=lambda: fetch_and_store_data(
                            ^^^^^^^^^^^^^^^^^^^^^
  File "/opt/airflow/dags/scraper_dag.py", line 42, in fetch_and_store_data
    initialize_cassandra()
  File "/opt/airflow/dags/scraper_dag.py", line 35, in initialize_cassandra
    cassandra_client.connect()
  File "/app/scraper/src/database/reference_data/cassandra_client.py", line 44, in connect
    self.cluster = Cluster(
                   ^^^^^^^^
  File "cassandra/cluster.py", line 1231, in cassandra.cluster.Cluster.__init__
cassandra.UnresolvableContactPoints: {}