asyncua.ua.uatypes WARNING - datetime overflow

[donatoaz]

Hi everyone!

I am using python 3.9.2, asyncua 0.9.98 on a raspberry pi running the latest pi os (i suppose it's based on ubuntu 20.04?).

I'm trying to figure out why I am getting these warnings from asyncua.ua.uatypes that datetime is overflowing.

2022-10-09 01:48:39,476 - asyncua.ua.uatypes - WARNING - datetime overflow: -2632920882442267668.
2022-10-09 01:48:40,483 - asyncua.ua.uatypes - WARNING - datetime overflow: -2632920882442267668.

The messages show up while I am sleeping.

This is part of my code:

class SubscriptionHandler:
    def __init__(self, callback):
        self._callback = callback

    def datachange_notification(self, node: Node, val, _data):
        try:
            self._callback(node, val)
        except Exception as err:
            _logger.error("Error in subscription callback")
            _logger.error(traceback.format_exception(type(err), err, err.__traceback__))
            pass


class Subscriber():
    def __init__(self, endpoint: str, publishing_interval: int = 5000, nodes: list[str] = []) -> None:
        self.endpoint = endpoint

        self._publishing_interval = publishing_interval
        self._nodes = nodes

        self.client = Client(url=endpoint)

    async def subscribe(self, callback):

        # check nodes and raise if empty, in the future we can choose to subscribe to all nodes
        
        await self.client.connect()
        # _nodes = await self.client.nodes.objects.get_child(["1:Temp"])
        handler = SubscriptionHandler(callback)
    
        self.subscription = await self.client.create_subscription(self._publishing_interval, handler)
        nodes = [
            self.client.get_node("ns=1;s=Temp")
        ]
    
        await self.subscription.subscribe_data_change(nodes)
    
    async def unsubscribe(self):
        await self.subscription.delete()
        await self.client.disconnect()

subscriber = Subscriber(opcua_endpoint, nodes=nodes)

async def run():
    def callback(node, value):
        payload = {
            "thingName": THING_NAME,
            "nodeId": node.nodeid.Identifier,
            "nodeValue": value,
            "timestamp": datetime.datetime.utcnow().strftime("%Y-%m-%d %H:%M:%S.%f"),
        }
        publish_message_to_topic(payload)

        logger.info(f"Published {payload} to {mqtt_topic}")

    await subscriber.subscribe(callback)

    try:
        while True:
            await asyncio.sleep(100)
    except:
        await subscriber.unsubscribe()


if __name__ == '__main__':
    loop = asyncio.new_event_loop()

    try:
        task = loop.create_task(run())
        loop.run_until_complete(task)
    except Exception as e:
        logger.warning("Caught interrupt in handler. Will stop task")
        logger.error(traceback.format_exception(type(e), e, e.__traceback__))
        task.cancel()
        loop.run_until_complete(task)
    finally:
        loop.close()