Обновить dags/split_subkonto2.py
This commit is contained in:
parent
8d2afb9615
commit
99feda4a3d
|
|
@ -267,6 +267,8 @@ def split_subkonto_from_1C(**kwargs):
|
||||||
from public.oborotno_salbdovaya_vedomostb osv
|
from public.oborotno_salbdovaya_vedomostb osv
|
||||||
where osv.subkonto2 not in (select dst2.subkonto2 from public.dict_subkonto_two dst2)
|
where osv.subkonto2 not in (select dst2.subkonto2 from public.dict_subkonto_two dst2)
|
||||||
""", engine)
|
""", engine)
|
||||||
|
if df.empty:
|
||||||
|
return pd.DataFrame(columns=['subkonto2', 'naimenovanie', 'nomer', 'date_begin', 'date_end'])
|
||||||
result_df = df['subkonto2'].apply(parse_contract_cell)
|
result_df = df['subkonto2'].apply(parse_contract_cell)
|
||||||
return result_df.to_dict(orient='records')
|
return result_df.to_dict(orient='records')
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue