xuan616 opened a new issue #18921:
URL: https://github.com/apache/airflow/issues/18921


   ### Description
   
   In the current 
[CassandraToGCSOperator](https://github.com/apache/airflow/blob/main/airflow/providers/google/cloud/transfers/cassandra_to_gcs.py#L40),
 
[session.execute()](https://github.com/apache/airflow/blob/main/airflow/providers/google/cloud/transfers/cassandra_to_gcs.py#L165)
 is only able to use the default timeout set by cassandra driver.
   
   The GH issue intends to support timeout as an argument in 
CassandraToGCSOperator so that the session can execute a query with the custom 
timeout.
   
   reference: 
[execute()](https://github.com/datastax/python-driver/blob/master/cassandra/cluster.py#L2575)
 in cassandra_driver
   
   
   ### Use case/motivation
   
   This support is going to make the query execution more flexible in cassandra 
operator for the use case where the query is expected to require a different 
timeout.
   
   ### Related issues
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [X] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to