bn_user
/
sigma
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Обновить dags/split_subkonto2.py

This commit is contained in:
bn_user 2025-09-09 14:23:43 +00:00
parent fb730103f0
commit a223dd924d
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dags/split_subkonto2.py
View File

@ -245,7 +245,9 @@ def parse_contract_cell(cell_text):
def read_dict_subkonto2_db(**kwargs): def read_dict_subkonto2_db(**kwargs):
engine = get_db_engine() engine = get_db_engine()
# Using triple quotes for better readability # Extract parameters from kwargs if needed
# param_value = kwargs.get('param_name')
query = """ query = """
SELECT DISTINCT SELECT DISTINCT
osv.schet as schet osv.schet as schet
@ -262,6 +264,8 @@ def read_dict_subkonto2_db(**kwargs):
""" """
try: try:
# If you need to pass parameters, do it like this:
# df = pd.read_sql(query, engine, params=(param_value,))
df = pd.read_sql(query, engine) df = pd.read_sql(query, engine)
return df.to_dict(orient='records') return df.to_dict(orient='records')
except Exception as e: except Exception as e: