fixes for registrar

core/registrar.py

@@ -172,7 +172,7 @@ def registrar(
             % objects_prefix
         )
 
-    product_type = data_package.split("/")[1]
+    product_type = data_package.split("/")[2]
 
     product, replaced = ProductRegistrator().register(
         metadata_locations=[[upload_container,
@@ -315,7 +315,7 @@ if __name__ == "__main__":
 
     setup_logging(arg_values.verbosity)
 
-    collection = os.environ.get('Collection')
+    collection = os.environ.get('COLLECTION')
     if collection is None:
         logger.critical("Collection environment variable not set.")
         sys.exit(1)

core/run-registrar.sh

@@ -2,4 +2,4 @@
 
 echo "Running registrar"
 
- python3 /registrar.py --mode redis --redis-host ${REDIS_HOST} --redis-port ${REDIS_PORT} --redis-register-queue-key ${REDIS_REGISTER_QUEUE_KEY} --redis-registered-set-key ${REDIS_REGISTERED_SET_KEY}
+python3 /registrar.py --mode redis --redis-host ${REDIS_HOST} --redis-port ${REDIS_PORT} --redis-register-queue-key ${REDIS_REGISTER_QUEUE_KEY} --redis-registered-set-key ${REDIS_REGISTERED_SET_KEY}