testing
This commit is contained in:
File diff suppressed because it is too large
Load Diff
+5
-2
@@ -1781,8 +1781,11 @@ def getsmallrowdata_db(columns, ids=[], doclean=True,workstrokesonly=True):
|
|||||||
|
|
||||||
if len(ids)>1:
|
if len(ids)>1:
|
||||||
for f in csvfilenames:
|
for f in csvfilenames:
|
||||||
df = dd.read_parquet(f,columns=columns,engine='pyarrow')
|
try:
|
||||||
data.append(df)
|
df = dd.read_parquet(f,columns=columns,engine='pyarrow')
|
||||||
|
data.append(df)
|
||||||
|
except OSError:
|
||||||
|
pass
|
||||||
|
|
||||||
|
|
||||||
df = dd.concat(data,axis=0)
|
df = dd.concat(data,axis=0)
|
||||||
|
|||||||
Reference in New Issue
Block a user