Skip to content
This repository was archived by the owner on Oct 13, 2018. It is now read-only.

Commit c5c877b

Browse files
committed
fix Queue limit
1 parent 1f5f152 commit c5c877b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

batch3dfier/batch3dfy.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,7 @@ def process_data(threadName, q):
189189
# Prep
190190
threadList = ["Thread-1", "Thread-2", "Thread-3"]
191191
queueLock = threading.Lock()
192-
workQueue = queue.Queue(10)
192+
workQueue = queue.Queue(0)
193193
threads = []
194194
threadID = 1
195195

@@ -231,7 +231,7 @@ def process_data(threadName, q):
231231
config.drop_2Dtiles(dbase, TILE_SCHEMA, views_to_drop=tiles_clipped)
232232

233233
# Delete temporary config files
234-
yml_cfg = [CFG_DIR + t + "_config.yml" for t in threadList]
234+
yml_cfg = [os.path.join(CFG_DIR, t + "_config.yml") for t in threadList]
235235
command = "rm"
236236
for c in yml_cfg:
237237
command = command + " " + c
@@ -245,5 +245,5 @@ def process_data(threadName, q):
245245
tiles_skipped = set(tiles_skipped)
246246
print("\nTotal number of tiles processed: " +
247247
str(len(tiles.difference(tiles_skipped))))
248-
print("Tiles skipped: " + str(tiles_skipped))
248+
print("Total number of tiles skipped: " + str(len(tiles_skipped)))
249249
print("Done.")

0 commit comments

Comments
 (0)