bug fix: with filter dataset
This commit is contained in:
parent
debbd48627
commit
87d54c508d
|
@ -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)
|
||||
|
||||
|
||||
|
||||
|
|
Loading…
Reference in New Issue