def from_dict()

in greengrasssdk/stream_manager/data/__init__.py [0:0]

• 39 lines of code
• 13 McCabe index (conditional complexity)

        def from_dict(d):
            v = {}
            if "exportConfigIdentifier" in d:
                v["export_config_identifier"] = (
                    str.from_dict(d["exportConfigIdentifier"])
                    if hasattr(str, "from_dict")
                    else d["exportConfigIdentifier"]
                )
            if "lastExportedSequenceNumber" in d:
                v["last_exported_sequence_number"] = (
                    int.from_dict(d["lastExportedSequenceNumber"])
                    if hasattr(int, "from_dict")
                    else d["lastExportedSequenceNumber"]
                )
            if "lastExportTime" in d:
                v["last_export_time"] = (
                    int.from_dict(d["lastExportTime"])
                    if hasattr(int, "from_dict")
                    else d["lastExportTime"]
                )
            if "errorMessage" in d:
                v["error_message"] = (
                    str.from_dict(d["errorMessage"])
                    if hasattr(str, "from_dict")
                    else d["errorMessage"]
                )
            if "exportedBytesFromStream" in d:
                v["exported_bytes_from_stream"] = (
                    int.from_dict(d["exportedBytesFromStream"])
                    if hasattr(int, "from_dict")
                    else d["exportedBytesFromStream"]
                )
            if "exportedMessagesCount" in d:
                v["exported_messages_count"] = (
                    int.from_dict(d["exportedMessagesCount"])
                    if hasattr(int, "from_dict")
                    else d["exportedMessagesCount"]
                )
            return MessageStreamInfo.exportStatuses(**v)