'Publish' not happening until script is done

[sscirrus]

I have a Python script that sometimes runs a process that lasts ~5-60 seconds. During this time, all its calls to session.publish() are ignored until the script is done. As soon as the time is up, all messages are published in a flood.

I have corroborated this by opening the Crossbar.io router in debug mode, and it shows logs corresponding to the published messages after the time is over (not during the run as expected).

My script is long, complex and includes a combined frontend and backend for Crossbar/Twisted/Autobahn. I feel I would risk misreporting if I tried to condense and include it.

What possible reason is there for publish to not happen instantaneously?

[David Ford]

your script isn't performing asynchronously

--
You received this message because you are subscribed to the Google Groups "Autobahn" group.
To unsubscribe from this group and stop receiving emails from it, send an email to autobahnws+...@googlegroups.com.
To post to this group, send email to autob...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/autobahnws/5c04c639-d1d7-45ca-81cd-994dc9abe84e%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[sscirrus]

Thanks for your message.

Here below is a specific example. How can I get the two `publish` commands in my_script() to publish 2s apart as the code suggests?

@component.on_join

@inlineCallbacks

def join(session, details):

    print("joined {}: {}".format(session, details))

         def publish(value):

        session.publish(u'com.asdf.ghjk', {"value": value})

    pass

    def my_script(thing):

        publish('TEST 1')
        sleep(2)

        publish('TEST 2')

    try:

        yield session.register(my_script, u'com.asdf.ghjk')

    except Exception as e:

        print("could not register procedure: {0}".format(e))

[David Ford]

is your tool based on asyncio or twisted?

To view this discussion on the web visit https://groups.google.com/d/msgid/autobahnws/f1452e40-edc2-43cc-8e58-a2a5872984c2%40googlegroups.com.

[sscirrus]

Twisted. With Crossbar and Autobahn.

[David Ford]

look at reactor.callLater(secs, callback, ...)

To view this discussion on the web visit https://groups.google.com/d/msgid/autobahnws/d575e5dd-62e4-4622-9699-4e5f95911a55%40googlegroups.com.

[sscirrus]

Thanks.