diff --git a/pysqa/queueadapter.py b/pysqa/queueadapter.py index dc5bf5cb..76bdb352 100644 --- a/pysqa/queueadapter.py +++ b/pysqa/queueadapter.py @@ -83,7 +83,10 @@ def __init__( self._adapter = self._queue_dict[primary_queue] elif queue_type is not None: self._queue_dict = {} - self._adapter = QueueAdapterCore(queue_type=queue_type.upper()) + self._adapter = QueueAdapterCore( + queue_type=queue_type.upper(), + execute_command=execute_command, + ) else: raise ValueError()