X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=examples%2Fallwatcher.py;h=ecd6e82cd730bfde280f4991e651cccbe68f8edb;hb=dcfcbc7b67df088f377c2a8c23dea32c20372aaf;hp=3f5ea06e39095be72c1909a54ffacd01f3cd9d2a;hpb=173b900fcd95b2436af55df2618302146f4a2f40;p=osm%2FN2VC.git diff --git a/examples/allwatcher.py b/examples/allwatcher.py index 3f5ea06..ecd6e82 100644 --- a/examples/allwatcher.py +++ b/examples/allwatcher.py @@ -1,15 +1,19 @@ +""" +This example: + +1. Connects to the current model +2. Starts an AllWatcher +3. Prints all changes received from the AllWatcher +4. Runs forever (kill with Ctrl-C) + +""" import asyncio import logging -logging.basicConfig(level=logging.DEBUG) from juju.client.connection import Connection from juju.client import watcher -loop = asyncio.get_event_loop() -conn = loop.run_until_complete(Connection.connect_current()) - - async def watch(): allwatcher = watcher.AllWatcher() allwatcher.connect(conn) @@ -18,4 +22,8 @@ async def watch(): for delta in change.deltas: print(delta.deltas) + +logging.basicConfig(level=logging.DEBUG) +loop = asyncio.get_event_loop() +conn = loop.run_until_complete(Connection.connect_current()) loop.run_until_complete(watch())