def decode()

in azure/functions/mysql.py [0:0]

• 20 lines of code
• 8 McCabe index (conditional complexity)

    def decode(cls,
               data: meta.Datum,
               *,
               trigger_metadata) -> typing.Optional[mysql.MySqlRowList]:
        if data is None or data.type is None:
            return None

        data_type = data.type

        if data_type in ['string', 'json']:
            body = data.value

        elif data_type == 'bytes':
            body = data.value.decode('utf-8')

        else:
            raise NotImplementedError(
                f'Unsupported payload type: {data_type}')

        rows = json.loads(body)
        if not isinstance(rows, list):
            rows = [rows]

        return mysql.MySqlRowList(
            (None if row is None else mysql.MySqlRow.from_dict(row))
            for row in rows)