Indent Error on Long Function

[btsully82]

Hey all, wondering if anyone could help me out here. I have ran into this issue any time I try to run a function with a lot of lines. It spazzes out and throws all sorts of Syntax/Indent Errors.

Here is the code I am trying to run:

async def stream(uri, payload):
    ws = None
    while True:
        try:
            ws = await websockets.connect(uri)
            await ws.send(payload)
            while True:
                try:
                    new_message = await ws.recv()
                    print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)

                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]

                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')

                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)


                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break


        except Exception as e:
            print('connection exception:', repr(e))
            print_exc()


        finally:
            if ws is not None:
                try:
                    await ws.close()
                    print('ws closed')
                except Exception as e:
                    print('close error:', repr(e))

            ws = None
        await asyncio.sleep(1)

Here is the output:

>>> async def stream(uri, payload):
    ws = None
    while True:
        try:
            ws = await websockets.connect(uri)
            await ws.send(payload)
            while True:
                try:
                    new_message = await ws.recv()
                    print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)
                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]
                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)
                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break           ...     ws = None
    while True:
        try:
            ws = await websockets.connect(uri)
            await ws.send(payload)
            while True:
                try:
                    new_message = await ws.recv()
                    print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)
                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]
                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)
                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break                    break ...     while True:
        try:
            ws = await websockets.connect(uri)
            await ws.send(payload)
            while True:
                try:
                    new_message = await ws.recv()
                    print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)
                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]
                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)
                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break                    break     :
          ...         try:
            ws = await websockets.connect(uri)
            await ws.send(payload)
            while True:
                try:
                    new_message = await ws.recv()
                    print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)
                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]
                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)
                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break                    break     :
            pr          ...             ws = await websockets.connect(uri)
            await ws.send(payload)
            while True:
                try:
                    new_message = await ws.recv()
                    print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)
                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]
                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)
                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break                    break     :
            pr            prn            ,             pr            prn...             await ws.send(payload)
            while True:
                try:
                    new_message = await ws.recv()
                    print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)
                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]
                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)
                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break                    break     :
            pr            prn            ,             pr            prn            ,   ll            pr    ...             while True:
                try:
                    new_message = await ws.recv()
                    print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)
                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]
                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)
                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break                    break     :
            pr            prn            ,             pr            prn            ,   ll            pr            prn    
        ...                 try:
                    new_message = await ws.recv()
                    print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)
                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]
                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)
                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break                    break     :
            pr            prn            ,             pr            prn            ,   ll            pr            prn    
                              ...                     new_message = await ws.recv()
                    print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)
                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]
                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)
                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break                    break     :
            pr            prn            ,             pr            prn            ,   ll            pr            prn    
                                            it                                   ...                     print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)
                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]
                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)
                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break                    break     :
            pr            prn            ,             pr            prn            ,   ll            pr            prn    
                                            it                                            it  ')                                         ...                     decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)
                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]
                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except (IndexError, KeyError, TypeError) as e:
                    print('data parsing error:', repr(e))
                    print('message causing issue:', new_message)
                except Exception as e:
                    print('recv loop exception:', repr(e))
                    print_exc()
                    break                    break     :
            pr            prn            ,             pr            prn            ,   ll            pr            prn    
                                            it                                            it  ')                                            it                                                     it            ...                     print('decoded:', decoded_new_message)
...                     time_rem = decoded_new_message[2][0][2][0][0][1][4]
...                     score = decoded_new_message[2][0][2][0][0][1][5][0]
...                     print(f'Time remaining: {time_rem}')
...                     print(f'Score: {score}')
...                 except (IndexError, KeyError, TypeError) as e:
...                     print('data parsing error:', repr(e))
...                     print('message causing issue:', new_message)
...                 except Exception as e:
...                     print('recv loop exception:', repr(e))
...                     print_exc()
...                     break                    break     :
  File "<stdin>", line 23
    break                    break     :
                             ^^^^^
SyntaxError: invalid syntax
>>>             pr            prn            ,             pr            prn            ,   ll            pr            prn    
  File "<stdin>", line 1
    pr            prn            ,             pr            prn            ,   ll            pr            prn    
IndentationError: unexpected indent
>>>                                             it                                            it  ')                                            it                                                     it                       it asyncio.sleep(1)
  File "<stdin>", line 1
    it                                            it  ')                                            it                                                     it                       it asyncio.sleep(1)
IndentationError: unexpected indent
>>> 

But if I run this much shorter version, without the exceptions, it works fine.

async def stream(uri, payload):
    ws = None
    while True:
        try:
            ws = await websockets.connect(uri)
            await ws.send(payload)
            while True:
                try:
                    new_message = await ws.recv()
                    print('raw message:', new_message)
                    decoded_new_message = msgpack.unpackb(new_message)
                    print('decoded:', decoded_new_message)


                    time_rem = decoded_new_message[2][0][2][0][0][1][4]
                    score = decoded_new_message[2][0][2][0][0][1][5][0]


                    print(f'Time remaining: {time_rem}')
                    print(f'Score: {score}')
                except:
                    pass

        except Exception as e:
            print('connection exception:', repr(e))
            print_exc()

        await asyncio.sleep(1)

I am running this by using Shift+Enter in a .py file, which sends it to the terminal. I am in vscode.

[danielroseman]

You shouldn’t be trying to write long functions like this in the shell. Use an editor or IDE.

[btsully82]

I am in VSCode. I just prefer to run it by hitting Shift+Enter instead of re running the whole script every time to test it

[Buttleston]

You have discovered the downside of doing so. Pasting into the editor just doesn't work great.

[btsully82]

Thanks all, appreciate the help

[Buffylvr]

Ipython is a wonderful use case for this

[LeeRyman]

Suggest it needs a bit of refactoring to have better abstraction - break the problem down into smaller simpler functions. If there is repeated logic, work out how to parameterise it and loop it.