Skip to content

Commit fdef6dd

Browse files
committed
Update SimpleQueue() to Queue()
1 parent be22000 commit fdef6dd

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

codeflare/pipelines/Runtime.py

+3-3
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@
4646
from sklearn.model_selection import BaseCrossValidator
4747
from enum import Enum
4848

49-
from queue import SimpleQueue
49+
from queue import Queue
5050
import pandas as pd
5151

5252

@@ -374,7 +374,7 @@ def select_pipeline(pipeline_output: dm.PipelineOutput, chosen_xyref: dm.XYRef)
374374
:return: Selected pipeline
375375
"""
376376
pipeline = dm.Pipeline()
377-
xyref_queue = SimpleQueue()
377+
xyref_queue = Queue()
378378

379379
xyref_queue.put(chosen_xyref)
380380
while not xyref_queue.empty():
@@ -411,7 +411,7 @@ def get_pipeline_input(pipeline: dm.Pipeline, pipeline_output: dm.PipelineOutput
411411
"""
412412
pipeline_input = dm.PipelineInput()
413413

414-
xyref_queue = SimpleQueue()
414+
xyref_queue = Queue()
415415
xyref_queue.put(chosen_xyref)
416416
while not xyref_queue.empty():
417417
curr_xyref = xyref_queue.get()

0 commit comments

Comments
 (0)