From 61da01f9e9d13c40d1f4b28f87ae261270f9f551 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Tue, 8 Aug 2023 10:26:52 -0500 Subject: [PATCH 1/2] bug fixes: console/cli handling --- transport/providers.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/transport/providers.py b/transport/providers.py index cf5ed59..a7de3d9 100644 --- a/transport/providers.py +++ b/transport/providers.py @@ -54,7 +54,8 @@ READ = {'sql':sql.SQLReader,'nosql':{MONGODB:mongo.MongoReader,COUCHDB:couch.Cou 'file':disk.DiskReader,'queue':{RABBIT:queue.QueueReader,QLISTENER:qlistener.qListener} } WRITE = {'sql':sql.SQLWriter,'nosql':{MONGODB:mongo.MongoWriter,COUCHDB:couch.CouchWriter},'cloud':sql.BigQueryWriter, - 'file':disk.DiskWriter,'queue':{RABBIT:queue.QueueWriter,QLISTENER:qlistener.qListener} + 'file':disk.DiskWriter,'queue':{RABBIT:queue.QueueWriter,QLISTENER:qlistener.qListener},'cli':{CONSOLE:Console},'memory':{CONSOLE:Console} + } DEFAULT = {PG:{'host':'localhost','port':5432},MYSQL:{'host':'localhost','port':3306}} DEFAULT[MONGODB] = {'port':27017,'host':'localhost'} From 55317e52573811f4425481a74c09a728dcc0571e Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Tue, 8 Aug 2023 10:29:55 -0500 Subject: [PATCH 2/2] bug fix --- transport/providers.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/transport/providers.py b/transport/providers.py index a7de3d9..4fe4784 100644 --- a/transport/providers.py +++ b/transport/providers.py @@ -51,7 +51,8 @@ CATEGORIES ={'sql':[NETEZZA,PG,MYSQL,REDSHIFT,SQLITE,MARIADB],'nosql':[MONGODB,C 'queue':[RABBIT,QLISTENER],'memory':[CONSOLE,QLISTENER],'http':[HTTP]} READ = {'sql':sql.SQLReader,'nosql':{MONGODB:mongo.MongoReader,COUCHDB:couch.CouchReader},'cloud':sql.BigQueryReader, - 'file':disk.DiskReader,'queue':{RABBIT:queue.QueueReader,QLISTENER:qlistener.qListener} + 'file':disk.DiskReader,'queue':{RABBIT:queue.QueueReader,QLISTENER:qlistener.qListener}, + 'cli':{CONSOLE:Console},'memory':{CONSOLE:Console} } WRITE = {'sql':sql.SQLWriter,'nosql':{MONGODB:mongo.MongoWriter,COUCHDB:couch.CouchWriter},'cloud':sql.BigQueryWriter, 'file':disk.DiskWriter,'queue':{RABBIT:queue.QueueWriter,QLISTENER:qlistener.qListener},'cli':{CONSOLE:Console},'memory':{CONSOLE:Console}