File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -118,7 +118,7 @@ def importThread(
118
118
db .execute (sql )
119
119
# db.commit()
120
120
121
- def parquatThread (
121
+ def parquetThread (
122
122
data : list ,
123
123
db : Connection ,
124
124
):
@@ -325,7 +325,7 @@ def importParquet(
325
325
chunk = round (entries / cores )
326
326
327
327
if entries <= chunk :
328
- resut = parquatThread (data , connections [0 ])
328
+ resut = parquetThread (data , connections [0 ])
329
329
timer .stop ()
330
330
return True
331
331
@@ -334,7 +334,7 @@ def importParquet(
334
334
block = 0
335
335
while block <= entries :
336
336
log .debug ("Dispatching Block %d:%d" % (block , block + chunk ))
337
- result = executor .submit (parquatThread , data [block : block + chunk ], connections [index ])
337
+ result = executor .submit (parquetThread , data [block : block + chunk ], connections [index ])
338
338
block += chunk
339
339
index += 1
340
340
executor .shutdown ()
You can’t perform that action at this time.
0 commit comments