def from_dict()

in greengrasssdk/stream_manager/data/__init__.py [0:0]
49 lines of code
17 McCabe index (conditional complexity)

    def from_dict(d):
        v = {}
        if "name" in d:
            v["name"] = (
                str.from_dict(d["name"]) if hasattr(str, "from_dict") else d["name"]
            )
        if "maxSize" in d:
            v["max_size"] = (
                int.from_dict(d["maxSize"])
                if hasattr(int, "from_dict")
                else d["maxSize"]
            )
        if "streamSegmentSize" in d:
            v["stream_segment_size"] = (
                int.from_dict(d["streamSegmentSize"])
                if hasattr(int, "from_dict")
                else d["streamSegmentSize"]
            )
        if "timeToLiveMillis" in d:
            v["time_to_live_millis"] = (
                int.from_dict(d["timeToLiveMillis"])
                if hasattr(int, "from_dict")
                else d["timeToLiveMillis"]
            )
        if "strategyOnFull" in d:
            v["strategy_on_full"] = (
                StrategyOnFull.from_dict(d["strategyOnFull"])
                if hasattr(StrategyOnFull, "from_dict")
                else d["strategyOnFull"]
            )
        if "persistence" in d:
            v["persistence"] = (
                Persistence.from_dict(d["persistence"])
                if hasattr(Persistence, "from_dict")
                else d["persistence"]
            )
        if "flushOnWrite" in d:
            v["flush_on_write"] = (
                bool.from_dict(d["flushOnWrite"])
                if hasattr(bool, "from_dict")
                else d["flushOnWrite"]
            )
        if "exportDefinition" in d:
            v["export_definition"] = (
                ExportDefinition.from_dict(d["exportDefinition"])
                if hasattr(ExportDefinition, "from_dict")
                else d["exportDefinition"]
            )
        return MessageStreamDefinition(**v)