Skip to content
Snippets Groups Projects
Commit cab89305 authored by Reinder Kraaij's avatar Reinder Kraaij :eye:
Browse files

Merge branch 'Add-Logging-for-RPC' into 'master'

Add Logging

See merge request !1069
parents e1dad5e3 4fb6e81a
No related branches found
No related tags found
1 merge request!1069Add Logging
Pipeline #112701 failed
Pipeline: tango

#112702

    ......@@ -127,6 +127,9 @@ run_unit_tests_coverage:
    package_files:
    stage: package
    needs:
    - trigger_prepare
    artifacts:
    expire_in: 1w
    paths:
    ......
    ......@@ -43,13 +43,33 @@ class AntennaField(antennafield_pb2_grpc.AntennafieldServicer):
    family = antenna_field_family_name(identifier.antennafield_name)
    db = tango.Database()
    device_exported = db.get_device_exported_for_class(family)
    logger.info(
    "Create_antennafield_device_proxy ANTENNA=%s FIELD=%s FAMILY=%s",
    identifier.antenna_name,
    identifier.antennafield_name,
    family,
    )
    for device_name in device_exported:
    _, _, exported_antenna_name = device_name.split("/")
    _, _, exported_antennafield_name = device_name.split("/")
    logger.info(
    "Found a device name in device_exported ANTENNA=%s FIELD=%s FAMILY=%s DEVICE_NAME=%s EXPORTED_ANTENNAFIELD_NAME=%s",
    identifier.antenna_name,
    identifier.antennafield_name,
    family,
    device_name,
    exported_antennafield_name,
    )
    if (
    exported_antenna_name.casefold()
    == identifier.antenna_name.casefold()
    exported_antennafield_name.casefold()
    == identifier.antennafield_name.casefold()
    ):
    logger.info(
    "We have a Match. ANTENNA=%s FIELD=%s FAMILY=%s DEVICE_NAME=%s",
    identifier.antenna_name,
    identifier.antennafield_name,
    family,
    device_name,
    )
    return create_device_proxy(device_name, write_access=write_access)
    except Exception as ex:
    logger.exception(
    ......@@ -62,9 +82,8 @@ class AntennaField(antennafield_pb2_grpc.AntennafieldServicer):
    raise IOError(
    f"Failed to create device proxy to '{identifier.antennafield_name}'"
    ) from ex
    else:
    raise ValueError(
    f"Antenna in Antenna field not found '{identifier.antennafield_name} '"
    f"Antenna '{identifier.antenna_name}' in Antenna field '{identifier.antennafield_name}' not found "
    )
    def _get_antenna_index(
    ......
    ......@@ -18,8 +18,8 @@ class TestAntennaField(base.TestCase):
    mock_db = MagicMock()
    mock_tango_database.return_value = mock_db
    mock_db.get_device_exported_for_class.return_value = [
    "STAT/AFL/Antenna1",
    "STAT/AFL/Antenna2", # This should match the identifier
    "STAT/AFL/LBA",
    "STAT/AFL/HBA", # This should match the identifier
    ]
    return mock_db
    ......@@ -42,7 +42,7 @@ class TestAntennaField(base.TestCase):
    # Assert
    mock_create_device_proxy.assert_called_once_with(
    "STAT/AFL/Antenna2", write_access=True
    "STAT/AFL/LBA", write_access=True
    )
    self.assertEqual(result, mock_device)
    ......
    0% Loading or .
    You are about to add 0 people to the discussion. Proceed with caution.
    Please register or to comment