Skip to content

Commit

Permalink
Merge pull request #310 from simonsobs/koopman/registry-session-data-…
Browse files Browse the repository at this point in the history
…docs

Update session.data example in main registry process
  • Loading branch information
BrianJKoopman authored Dec 15, 2022
2 parents 819e5e5 + 6089358 commit 94b5861
Show file tree
Hide file tree
Showing 2 changed files with 49 additions and 27 deletions.
40 changes: 25 additions & 15 deletions docs/agents/registry.rst
Original file line number Diff line number Diff line change
Expand Up @@ -73,21 +73,31 @@ since the registry started running::

which will print a dictionary that might look like::

{'observatory.aggregator':
{'expired': False,
'last_updated': 1583179794.5175,
'time_expired': None,
'op_codes': {'record': 3}},
'observatory.faker1':
{'expired': False,
'last_updated': 1583179795.072248,
'time_expired': None,
'op_codes': {'acq': 3, 'set_heartbeat': 1, 'delay_task': 1}},
'observatory.faker2':
{'expired': True,
'last_updated': 1583179777.0211036,
'time_expired': 1583179795.3862052,
'op_codes': {'acq': 3, 'set_heartbeat': 1, 'delay_task': 1}}}
{
"observatory.aggregator": {
"expired": False,
"time_expired": None,
"last_updated": 1669925713.4082503,
"op_codes": {
"record": 3
},
"agent_class": "AggregatorAgent",
"agent_address": "observatory.aggregator"
},
"observatory.fake-hk-agent-01": {
"expired": False,
"time_expired": None,
"last_updated": 1669925945.7575383,
"op_codes": {
"acq": 3,
"set_heartbeat": 1,
"delay_task": 1
},
"agent_class": "FakeDataAgent",
"agent_address": "observatory.fake-hk-agent-01"
}
}


.. _operation_monitor:

Expand Down
36 changes: 24 additions & 12 deletions ocs/agents/registry/agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -161,18 +161,30 @@ def main(self, session: ocs_agent.OpSession, params):
lifetime of the Registry. For instance, this might look like::
>>> response.session['data']
{'observatory.aggregator':
{'expired': False,
'last_updated': 1583179794.5175,
'time_expired': None},
'observatory.faker1':
{'expired': False,
'last_updated': 1583179795.072248,
'time_expired': None},
'observatory.faker2':
{'expired': True,
'last_updated': 1583179777.0211036,
'time_expired': 1583179795.3862052}}
{
"observatory.aggregator": {
"expired": False,
"time_expired": None,
"last_updated": 1669925713.4082503,
"op_codes": {
"record": 3
},
"agent_class": "AggregatorAgent",
"agent_address": "observatory.aggregator"
},
"observatory.fake-hk-agent-01": {
"expired": False,
"time_expired": None,
"last_updated": 1669925945.7575383,
"op_codes": {
"acq": 3,
"set_heartbeat": 1,
"delay_task": 1
},
"agent_class": "FakeDataAgent",
"agent_address": "observatory.fake-hk-agent-01"
}
}
"""

Expand Down

0 comments on commit 94b5861

Please sign in to comment.