From 87d54c508dd51a4929a593ef76dd723ee8396b60 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Wed, 1 Apr 2020 02:36:22 -0500 Subject: [PATCH] bug fix: with filter dataset --- finalize.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/finalize.py b/finalize.py index fd50d1d..5310e6d 100644 --- a/finalize.py +++ b/finalize.py @@ -66,7 +66,7 @@ class Utils : # Let us load the filter in the SQL Query FILTER = item['filter'] QUALIFIER = REVERSE_QUALIFIER[FILTER['qualifier'].upper()] - SQL_FILTER += [" ".join([FILTER['field'], QUALIFIER,'(',FILTER['value'],')'])] + SQL_FILTER += [" ".join([FILTER['field'], QUALIFIER,'(',FILTER['value'],')']).replace(":dataset",args['dataset'])] src = ".".join([args['dataset'],args['from']]) SQL += [" AND ".join(SQL_FILTER)] # @@ -126,7 +126,8 @@ def move (**args): SQL = SQL.replace("*"," , ".join(fields)) # print (SQL) out = client.query(SQL,location='US',job_config=config) - print (dir (out)) + print () + print (out.job_id)