Skip to content

Commit

Permalink
Fix flake8
Browse files Browse the repository at this point in the history
  • Loading branch information
auxten committed Jan 3, 2025
1 parent eebaf38 commit 20e2185
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 1 deletion.
2 changes: 1 addition & 1 deletion .github/workflows/pr_ci.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -27,5 +27,5 @@ jobs:
run: python -m pip install flake8

- name: Run flake8 on chdb directory
run: flake8 chdb
run: cd chdb && flake8 .

3 changes: 3 additions & 0 deletions chdb/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
import os
import threading


class ChdbError(Exception):
"""Base class for exceptions in this module."""

Expand Down Expand Up @@ -65,9 +66,11 @@ def to_df(r):
t = to_arrowTable(r)
return t.to_pandas(use_threads=True)


# global connection lock, for multi-threading use of legacy chdb.query()
g_conn_lock = threading.Lock()


# wrap _chdb functions
def query(sql, output_format="CSV", path="", udf_path=""):
global g_udf_path
Expand Down

0 comments on commit 20e2185

Please sign in to comment.