def __init__()

in elastic/shared/parameter_sources/datastream.py [0:0]

• 17 lines of code
• 6 McCabe index (conditional complexity)

    def __init__(self, track, params, **kwargs):
        self._params = params
        self.infinite = False
        target_data_stream = params.get("data-stream")
        data_stream_definitions = []
        if target_data_stream:
            if isinstance(target_data_stream, str):
                target_data_stream = [target_data_stream]
            for data_stream in target_data_stream:
                data_stream_definitions.append(data_stream)
        elif track.data_streams:
            for data_stream in track.data_streams:
                data_stream_definitions.append(data_stream.name)
        else:
            raise exceptions.InvalidSyntax(f"{params.get('operation-type')} operation targets no data streams")
        self._wait_for_status = track.selected_challenge_or_default.parameters.get("wait-for-status", None)
        self._target_data_stream = iter(data_stream_definitions)