scheduler should decode credentials

2017-06-15 03:59:51 -05:00
parent a02538549b
commit 0c3662fb6d
2 changed files with 3 additions and 3 deletions
@@ -1158,7 +1158,7 @@ class Scheduler(MetaScheduler):
        if not self.db_thread:
            logger.debug('thread building own DAL object')
            self.db_thread = DAL(
-                self.db._uri, folder=self.db._adapter.folder)
+                self.db._uri, folder=self.db._adapter.folder, decode_credentials=True)
            self.define_tables(self.db_thread, migrate=False)
        try:
            db = self.db_thread
@@ -1698,7 +1698,7 @@ def main():
    print('groups for this worker: ' + ', '.join(group_names))
    print('connecting to database in folder: ' + options.db_folder or './')
    print('using URI: ' + options.db_uri)
-    db = DAL(options.db_uri, folder=options.db_folder)
+    db = DAL(options.db_uri, folder=options.db_folder, decode_credentials=True)
    print('instantiating scheduler...')
    scheduler = Scheduler(db=db,
                          worker_name=options.worker_name,