Revision 5bfb1134

b/lib/watcher/__init__.py
629 629
  """Retrieves instances and nodes per node group.
630 630

  
631 631
  """
632
  # TODO: Implement locking
633 632
  job = [
634 633
    # Get all primary instances in group
635 634
    opcodes.OpQuery(what=constants.QR_INSTANCE,
636 635
                    fields=["name", "status", "admin_state", "snodes",
637 636
                            "pnode.group.uuid", "snodes.group.uuid"],
638
                    filter=[qlang.OP_EQUAL, "pnode.group.uuid", uuid]),
637
                    filter=[qlang.OP_EQUAL, "pnode.group.uuid", uuid],
638
                    use_locking=True),
639 639

  
640 640
    # Get all nodes in group
641 641
    opcodes.OpQuery(what=constants.QR_NODE,
642 642
                    fields=["name", "bootid", "offline"],
643
                    filter=[qlang.OP_EQUAL, "group.uuid", uuid]),
643
                    filter=[qlang.OP_EQUAL, "group.uuid", uuid],
644
                    use_locking=True),
644 645
    ]
645 646

  
646 647
  job_id = cl.SubmitJob(job)

Also available in: Unified diff