File tree Expand file tree Collapse file tree 1 file changed +39
-0
lines changed
extensions/eda/plugins/event_emitter Expand file tree Collapse file tree 1 file changed +39
-0
lines changed Original file line number Diff line number Diff line change 1+ #!/usr/bin/env python3
2+ """
3+ template.py
4+
5+ An ansible-rulebook event emitter plugin template.
6+
7+ Examples:
8+ sources:
9+ - template:
10+
11+ """
12+ import asyncio
13+ from typing import Any , Dict
14+
15+
16+ async def main (queue : asyncio .Queue , args : Dict [str , Any ]):
17+ delay = args .get ("delay" , 0 )
18+
19+ while True :
20+ message = await queue .get ()
21+ if message is None :
22+ break
23+ print (message )
24+
25+
26+ if __name__ == "__main__" :
27+
28+ class MockQueue :
29+ count = 10
30+ async def get (self ):
31+ self .count -= 1
32+ if self .count == 0 :
33+ return None
34+ else :
35+ return {'message' : 'hello world' }
36+
37+ mock_arguments = dict ()
38+ asyncio .run (main (MockQueue (), mock_arguments ))
39+
You can’t perform that action at this time.
0 commit comments