def as_dict()

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

• 45 lines of code
• 15 McCabe index (conditional complexity)

    def as_dict(self):
        d = {}
        if self.__identifier is not None:
            d["identifier"] = (
                self.__identifier.as_dict()
                if hasattr(self.__identifier, "as_dict")
                else self.__identifier
            )
        if self.__kinesis_stream_name is not None:
            d["kinesisStreamName"] = (
                self.__kinesis_stream_name.as_dict()
                if hasattr(self.__kinesis_stream_name, "as_dict")
                else self.__kinesis_stream_name
            )
        if self.__batch_size is not None:
            d["batchSize"] = (
                self.__batch_size.as_dict()
                if hasattr(self.__batch_size, "as_dict")
                else self.__batch_size
            )
        if self.__batch_interval_millis is not None:
            d["batchIntervalMillis"] = (
                self.__batch_interval_millis.as_dict()
                if hasattr(self.__batch_interval_millis, "as_dict")
                else self.__batch_interval_millis
            )
        if self.__priority is not None:
            d["priority"] = (
                self.__priority.as_dict()
                if hasattr(self.__priority, "as_dict")
                else self.__priority
            )
        if self.__start_sequence_number is not None:
            d["startSequenceNumber"] = (
                self.__start_sequence_number.as_dict()
                if hasattr(self.__start_sequence_number, "as_dict")
                else self.__start_sequence_number
            )
        if self.__disabled is not None:
            d["disabled"] = (
                self.__disabled.as_dict()
                if hasattr(self.__disabled, "as_dict")
                else self.__disabled
            )
        return d