Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion providers/clickhousedb/docs/connections/clickhouse.rst
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ Extra (optional)
field adds a human-readable suffix, e.g. ``"my-pipeline"``.
* ``session_settings`` *(dict)*: ClickHouse session-level settings applied to every
query on this connection. These are passed directly to the ``settings`` parameter of
``clickhouse_connect.connect()``. Common examples:
``clickhouse_connect.get_client()``. Common examples:

.. code-block:: json

Expand Down
2 changes: 1 addition & 1 deletion providers/clickhousedb/docs/index.rst
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@
:maxdepth: 1
:caption: Resources

Example Dags <https://github.com/apache/airflow/tree/providers-clickhouse/|version|/providers/clickhouse/tests/system/clickhouse>
Example Dags <https://github.com/apache/airflow/tree/providers-clickhousedb/|version|/providers/clickhousedb/tests/system/clickhouse>
PyPI Repository <https://pypi.org/project/apache-airflow-providers-clickhousedb/>
Installing from sources <installing-providers-from-sources>

Expand Down
4 changes: 3 additions & 1 deletion providers/clickhousedb/docs/operators/clickhouse.rst
Original file line number Diff line number Diff line change
Expand Up @@ -62,14 +62,16 @@ An example usage of the SQLExecuteQueryOperator to connect to ClickHouse:
Querying Data
^^^^^^^^^^^^^

Use a ``handler`` to return query results:
Query results are fetched with the default ``handler`` (``fetch_all_handler``):

.. exampleinclude:: /../../clickhousedb/tests/system/clickhouse/example_clickhouse.py
:language: python
:start-after: [START howto_operator_clickhouse_query]
:end-before: [END howto_operator_clickhouse_query]
:dedent: 4

To return something other than the full result set, pass a custom ``handler``. For example, ``fetch_one_handler`` to fetch only the first row.

.. note::

``session_settings`` passed to :class:`~airflow.providers.clickhousedb.hooks.clickhouse.ClickHouseHook`
Expand Down
Loading