yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-11-03 12:16:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: apply code review remarks

Browse Source
This commit is contained in:
Rafal Kluszczynski 2016-05-24 22:39:59 +02:00
parent ee1e36219a
commit 457b0c0a2e
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
metadata-etl/src/main/resources/jython/DatasetTreeBuilder.py
View File

@ -83,7 +83,7 @@ class DatasetTreeBuilder:
def saveTreeInElasticSearchIfApplicable(args): def saveTreeInElasticSearchIfApplicable(args):
es_url = args.get(Constant.WH_ELASTICSEARCH_URL_KEY, None) es_url = args.get(Constant.WH_ELASTICSEARCH_URL_KEY, None)
es_port = args.get(Constant.WH_ELASTICSEARCH_PORT_KEY, None) es_port = args.get(Constant.WH_ELASTICSEARCH_PORT_KEY, None)
if es_url is not None and es_port is not None: if es_url and es_port:
esi = ElasticSearchIndex(args) esi = ElasticSearchIndex(args)
d = datetime.utcnow() d = datetime.utcnow()
unixtime = calendar.timegm(d.utctimetuple()) unixtime = calendar.timegm(d.utctimetuple())

2
metadata-etl/src/main/resources/jython/FlowTreeBuilder.py
View File

@ -86,7 +86,7 @@ class FlowTreeBuilder:
def saveTreeInElasticSearchIfApplicable(args): def saveTreeInElasticSearchIfApplicable(args):
es_url = args.get(Constant.WH_ELASTICSEARCH_URL_KEY, None) es_url = args.get(Constant.WH_ELASTICSEARCH_URL_KEY, None)
es_port = args.get(Constant.WH_ELASTICSEARCH_PORT_KEY, None) es_port = args.get(Constant.WH_ELASTICSEARCH_PORT_KEY, None)
if es_url is not None and es_port is not None: if es_url and es_port:
esi = ElasticSearchIndex(args) esi = ElasticSearchIndex(args)
d = datetime.utcnow() d = datetime.utcnow()
unixtime = calendar.timegm(d.utctimetuple()) unixtime = calendar.timegm(d.utctimetuple())