From 78ad8f3ad83ac0b64fd46d52c6bc7713a0c720e7 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Tue, 30 May 2023 15:19:10 -0500 Subject: [PATCH] bug fix: etl transport --- transport/etl.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/transport/etl.py b/transport/etl.py index 83018e6..d509005 100644 --- a/transport/etl.py +++ b/transport/etl.py @@ -106,8 +106,8 @@ class ETL (Process): # self.sql = _args['source']['sql'] if 'sql' in _args['source'] else None # self.cmd = _args['source']['cmd'] if 'cmd' in _args['source'] else None # self._oargs = _args['target'] #transport.factory.instance(**_args['target']) - self._source = dict(_args ['source'],**{'context':'write'}) - self._target = dict(_args['target'],**{'context':'read','lock':True}) + self._source = _args['source'] #dict(_args ['source'],**{'context':'write'}) + self._target = _args['target'] #dict(_args['target'],**{'context':'read','lock':True}) self.JOB_COUNT = _args['jobs'] self.jobs = []