Fixed hardcoded schema for Queue manager

lsst-dm · Nov 7, 2024 · 626f148 · 626f148
1 parent f4b416d
commit 626f148
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/python/lsst/consdb/efd_transform/transform_efd.py b/python/lsst/consdb/efd_transform/transform_efd.py
@@ -224,8 +224,7 @@ async def main() -> None:
     )
 
     # Instantiate the queue manager
-    # TODO: Set schema by instrument
-    qm = QueueManager(db_uri=consdb_url, schema="cdb_latiss", logger=log)
+    qm = QueueManager(db_uri=consdb_url, schema=tm.get_schema_by_instrument(args.instrument), logger=log)
 
     start_time = None
     if args.start_time is not None: