Fix observation status batch program

shikshalokam · May 5, 2021 · 9ad9816 · 9ad9816
1 parent 9e0369f
commit 9ad9816
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/observations/pyspark_observation_status_batch.py b/observations/pyspark_observation_status_batch.py
@@ -90,10 +90,10 @@ def convert_to_row(d: dict) -> Row:
 
 clientProd = MongoClient(config.get('MONGO', 'mongo_url'))
 db = clientProd[config.get('MONGO', 'database_name')]
-obsSubmissionsCollec = db[config.get('MONGO',' observation_sub_collec')]
+obsSubmissionsCollec = db[config.get('MONGO', 'observation_sub_collec')]
 solutionCollec = db[config.get('MONGO', 'solutions_collec')]
-userRolesCollec = db[config.get("MONGO", "user_roles_collection")]
-programCollec = db[config.get("MONGO", "programs_collec")]
+userRolesCollec = db[config.get("MONGO", 'user_roles_collection')]
+programCollec = db[config.get("MONGO", 'programs_collec')]
 
 # redis cache connection 
 redis_connection = redis.ConnectionPool(