ó O'—^c@@sVddlmZddlmZddlmZmZmZdefd„ƒYZdS(i(tabsolute_import(t Connection(tCasetSkipTesttpatchttest_sqlalchemycB@s5eZd„Zd„Zd„Zd„Zd„ZRS(cC@s4yddl}Wntk r/tdƒ‚nXdS(Nissqlalchemy not installed(t sqlalchemyt ImportErrorR(tselfR((sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_sqlalchemy.pytsetUp s c C@sotdƒ]d}t|ƒjƒd}t|ƒjƒd}|jtƒt|ƒjƒWdQXWdQXdS(Ns(kombu.transport.sqlalchemy.Channel._opens$sqlalchemy+sqlite:///celerydb.sqlitessqla+sqlite:///celerydb.sqlitessqlb+sqlite:///celerydb.sqlite(RRtconnectt assertRaisestKeyError(Rturl((sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_sqlalchemy.pyttest_url_parsers cC@sƒtdƒ}|jƒ|jƒ}|j|jjjdƒ|j|jjjdƒ|jddƒ|j dƒdkst ‚dS(Nssqlalchemy+sqlite:///:memory:t kombu_queuet kombu_messagetcelerytDATA( RR tchannelt assertEqualt queue_clst __table__tnamet message_clst_putt_gettAssertionError(RtconnR((sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_sqlalchemy.pyttest_simple_queueings     cC@sŁtdƒ‚tddidd6dd6ƒ}|jƒ|jƒ}|j|jjjdƒ|j|jjjdƒ|j dd ƒ|j dƒd ksŸt ‚dS( Nscauses global side effectssqlalchemy+sqlite:///:memory:ttransport_optionstmy_custom_queuetqueue_tablenametmy_custom_messagetmessage_tablenameRR( RRR RRRRRRRRR(RRR((sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_sqlalchemy.pyttest_custom_table_names+s       cC@s}d}tdjd|gƒƒ}|j|jdƒ|j|j|ƒ|jƒ}|j|j|ƒ|j|jdƒdS(Nssqlite:///celerydb.sqlitet+tsqla(RtjoinRt uri_prefixthostnametclone(RR(txR)((sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_sqlalchemy.pyt test_clone>s (t__name__t __module__R RRR#R+(((sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_sqlalchemy.pyRs    N( t __future__RtkombuRtkombu.tests.caseRRRR(((sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_sqlalchemy.pyts