Skip to content

P
preprocess-data
Commit e5e018c7 authored by dasharatha.vamshi's avatar dasharatha.vamshi
Browse files
Options

az down

parent 9fe429a7
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
main.py
View file @ e5e018c7
...@@ -91,7 +91,7 @@ if __name__ == '__main__': ...@@ -91,7 +91,7 @@ if __name__ == '__main__':
if PreProcessConstants.STANDARD_SCALAR_PATH in config.keys(): if PreProcessConstants.STANDARD_SCALAR_PATH in config.keys():
standard_scalar_path = config[PreProcessConstants.STANDARD_SCALAR_PATH] standard_scalar_path = config[PreProcessConstants.STANDARD_SCALAR_PATH]
try: try:
my_path = PreProcessConstants.AZURE_FILE_PATH + tag_dir + standard_scalar_path.split('/')[-1] my_path = PreProcessConstants.AZURE_FILE_PATH + tag_dir + "/" + standard_scalar_path.split('/')[-1]
logger.info("Azure file path " + my_path) logger.info("Azure file path " + my_path)
x = azure_download(my_path, standard_scalar_path) x = azure_download(my_path, standard_scalar_path)
if x: if x:
......
scripts/common/config_parser.py
View file @ e5e018c7
...@@ -40,9 +40,9 @@ if READ_FROM_MONGO: ...@@ -40,9 +40,9 @@ if READ_FROM_MONGO:
raise Exception('No job in progress') raise Exception('No job in progress')
_tag_hierarchy = get_run_info['job_metadata']['in_progress'][0] _tag_hierarchy = get_run_info['job_metadata']['in_progress'][0]
tag_path = _tag_hierarchy
sys.stdout.write(f"_tag_hierarchy --> {_tag_hierarchy}\n") sys.stdout.write(f"_tag_hierarchy --> {_tag_hierarchy}\n")
_tag_hierarchy = _tag_hierarchy.split('$') _tag_hierarchy = _tag_hierarchy.split('$')
tag_path = _tag_hierarchy
site_id = _tag_hierarchy[0] site_id = _tag_hierarchy[0]
dept_id = _tag_hierarchy[1] dept_id = _tag_hierarchy[1]
line_id = _tag_hierarchy[2] line_id = _tag_hierarchy[2]
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment