ASDFASDFAS
This commit is contained in:
parent
fe07e61505
commit
a60cfae01c
17
app.py
17
app.py
@ -48,7 +48,7 @@ def convert_pdf_to_image(pdf_path):
|
|||||||
return None
|
return None
|
||||||
|
|
||||||
# Function to print address labels
|
# Function to print address labels
|
||||||
def print_address_label(pdf_path):
|
def print_address_label(pdf_path, print_complete_event):
|
||||||
try:
|
try:
|
||||||
# Convert PDF to image
|
# Convert PDF to image
|
||||||
image = convert_pdf_to_image(pdf_path)
|
image = convert_pdf_to_image(pdf_path)
|
||||||
@ -96,6 +96,10 @@ def print_address_label(pdf_path):
|
|||||||
except Exception as e:
|
except Exception as e:
|
||||||
app.logger.error(f"Error during printing: {str(e)}")
|
app.logger.error(f"Error during printing: {str(e)}")
|
||||||
|
|
||||||
|
finally:
|
||||||
|
# Signal that the current print job is done
|
||||||
|
print_complete_event.set()
|
||||||
|
|
||||||
# Worker thread that processes files from the queue
|
# Worker thread that processes files from the queue
|
||||||
def process_queue():
|
def process_queue():
|
||||||
while True:
|
while True:
|
||||||
@ -103,10 +107,17 @@ def process_queue():
|
|||||||
file_path = file_queue.get()
|
file_path = file_queue.get()
|
||||||
if file_path is None: # Shutdown signal
|
if file_path is None: # Shutdown signal
|
||||||
break
|
break
|
||||||
|
|
||||||
|
# Create an event to signal print job completion
|
||||||
|
print_complete_event = threading.Event()
|
||||||
|
|
||||||
# Process the file (convert and print)
|
# Process the file (convert and print)
|
||||||
app.logger.info(f"Processing file: {file_path}")
|
app.logger.info(f"Processing file: {file_path}")
|
||||||
print_address_label(file_path)
|
print_address_label(file_path, print_complete_event)
|
||||||
time.sleep(10)
|
|
||||||
|
# Wait until the current print job is completed before processing the next one
|
||||||
|
print_complete_event.wait()
|
||||||
|
|
||||||
# Signal that the task is done
|
# Signal that the task is done
|
||||||
file_queue.task_done()
|
file_queue.task_done()
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user