#NEWLINE# def __new__( cls , mode = 'async' , * args , **kwargs ) : #NEWLINE# #INDENT# if ( cls == 'async' ) : #NEWLINE# #INDENT# from zenqueue.queue import async #NEWLINE# return async . Queue ( * args , ** kwargs ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( mode == 'sync' ) : #NEWLINE# #INDENT# from zenqueue.queue import sync #NEWLINE# return sync . Queue ( * args , ** kwargs ) #NEWLINE# #UNINDENT# #UNINDENT# raise ValueError ( ( 'Invalid queue mode: %r' % ( mode , ) ) )