Monitoring existing position give this warning

[aureliano90]

Monitoring existing position give this warning

[Aureliano90]

You have to elaborate your question. Or just use the latest commit.

[Aureliano90]

Thanks for reporting. This is really an exotic issue. It comes down to how multiprocessing create child processes in different OS. In Linux the child processes are forked from the main one, so is the event loop. It causes the event loops in different processes to mix up.

Once it works, the program will manage your position on its own, assuming it is already hedged. You can close your position manually at your wish. Or the program will close it when it isn't profitable.

[panpansh]

thank you for your precise answer. so it doesn't block anything in theory or doesn't miss anything by not expecting it? how do I really know if I'm not going to wait forever? :) can there be a way to solve this different management in order to obtain a uniform behavior so as not to have any surprises?

[panpansh]

Hey what is the problem about fetch_records_lock variable access please ? (I dont know python by default). This one is in order to avoid starting another record_ticker process ? maybe I dont how it is managed.

Then what do you think to start it as service with sys.argv[1] == '--service' ?

do we agree that in this way I could issue orders from another python instance and everything will happen on its own ?
what is the strategy path please ?

def main_menu(accountid: int):
    """主菜单

    :param accountid: 账号id
    """
    fetch_records_lock = False           # ?
    try:
        assert isinstance(accountid, int)
        fprint(f'{accountid=}')
        Monitor = monitor.Monitor(coin='BTC', accountid=accountid)
        loop = asyncio.get_event_loop()
        loop.run_until_complete(gather(Monitor.check_account_level(), Monitor.check_position_mode()))
        def fetch_records():
            if not fetch_records_lock:           # ?
                record_process = multiprocessing.Process(target=record.record_ticker)
                record_process.start()
                record_process.join(0.2)
                fetch_records_lock = True           # ?
            else:
                print('fetch ticker already started')
        if len(sys.argv) > 1 and sys.argv[1] == '--service':
                fetch_records()
        else:
            while (command := input(main_menu_text)) != 'q':
                if command == '1':
                    monitor_all(accountid)
                elif command == '2':
                    crypto_menu(accountid)
                elif command == '3':
                    funding_menu(accountid)
                elif command == '4':
                    account_menu(accountid)
                elif command == '5':
                    fetch_records()
                elif command == 'q':
                    break
                else:
                    print(wrong_command)
    finally:
        if 'process' in locals():
            process.kill()
        trading_data.Stat.clean()
        monitor.Monitor.clean()

[Aureliano90]

You can add the service yourself. As long as a Python interpreter is recording, others use the same database. I don't know what you mean by strategy path.

[panpansh]

I have to take the time to understand I will start with that especially 🙏

[panpansh]

when I start the monitor process on windows, I cant "Input q to abort" with the last update. I have to Ctrl+C to exit.

Process Process-1:
Process Process-2:
Traceback (most recent call last):
Traceback (most recent call last):

[Aureliano90]

The child processes don't receive stdin.

…

On Sat, Apr 9, 2022, 16:49 panpansh ***@***.***> wrote: when I start the monitor process on windows, I cant "Input q to abort" with the last update. I have to Ctrl+C to exit. Process Process-1: Process Process-2: Traceback (most recent call last): Traceback (most recent call last): — Reply to this email directly, view it on GitHub <#6 (comment)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/ATPXLOPBNICVIWDYWFUZTILVEH3NJANCNFSM5S5G4XOQ> . You are receiving this because you modified the open/close state.Message ID: ***@***.*** .com>

[panpansh]

can you help me to send "self" here please ?
https://github.com/panpansh/Futures-Spot-Arbitrage-OKEx-V5/blob/main/menu.py#L222
is it monitoring BTC positions only here ?
https://github.com/panpansh/Futures-Spot-Arbitrage-OKEx-V5/blob/main/menu.py#L215

do you have a discord or something like that ?

[Aureliano90]

What do you mean by "send self"?

It's just checking account settings.