Skip to content

Commit 5bdc1ef

Browse files
committed
Py 3 doesn't have Queue module, use multiprocessing.queue instead
1 parent 550c406 commit 5bdc1ef

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

cwltool/sandboxjs.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import select
77
import subprocess
88
import threading
9-
import Queue
9+
from multiprocessing import Queue
1010
import sys
1111
from io import BytesIO
1212
from typing import Any, Dict, List, Mapping, Text, Tuple, Union
@@ -155,9 +155,9 @@ def term():
155155
READ_BYTES_SIZE = 512
156156

157157
# creating queue for reading from a thread to queue
158-
input_queue = Queue.Queue()
159-
output_queue = Queue.Queue()
160-
error_queue = Queue.Queue()
158+
input_queue = Queue()
159+
output_queue = Queue()
160+
error_queue = Queue()
161161

162162
# To tell threads that output has ended and threads can safely exit
163163
no_more_output = threading.Lock()

0 commit comments

Comments
 (0)