Skip to content

Neyberson/subscribe #42

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Merged
merged 33 commits into from
Sep 23, 2024
Merged

Neyberson/subscribe #42

merged 33 commits into from
Sep 23, 2024

Conversation

neyberson
Copy link
Contributor

No description provided.

neyberson and others added 30 commits September 17, 2024 09:19
@neyberson
Create subscribe_once() in session.py
a9700bb
@neyberson
Create _execution_started_cd() in session.py
f640832
@neyberson
Use _execution_started_cd() and delete print_obj() in session.py:subs…
d9eb6a1 
…cribe_once()
@neyberson
Move execution_started_cd() into subscribe_once()
2415bae
@neyberson
Create task using subscribe() in session.py:subscribe_once()
74ec316
@neyberson
Format session.py
c97e8b5
@neyberson
Fix creating and use of future in subscribe_once()
8c3712d
@neyberson
Add repeating default value in session.py:subscribe()
93ccfdf
@neyberson
Add subscriptions_futures attribute in Session
47ddb1a
@neyberson
Add conditionals to use subscriptions_futures in subscribe_once()
5806e61
@neyberson
Change string to future in the list in subscribe_once()
f0a6f8f
@neyberson
Save tuples with callbacks and futures in subscribe_once()
cc0c83a
@neyberson
Add loop to use the callback of subscriptions_futures in run_read_loop()
678fd49
@neyberson
Add future parameter in execution_started_cd() of subscribe_once()
2ec86b2
@neyberson
Use future in the callback and add debugs in run_read_loop
e4ae791
@neyberson
Delete execution_started_cd() in session.py:subscribe_once()
9c2c737
@neyberson
Delete callback strategy and use set_result in run_read_loop()
6d0df40
@neyberson
Delete future verification of subscriptions_futures in run_read_loop()
e16aa8c
@neyberson
Copy futures list and verify futures to delete of session.subscriptio…
357598c 
…ns_futures
@neyberson
Simplify code in subscriptions_futures loop of run_read_loop()
ddb6a2d
@neyberson
Delete conditional about future.done() in run_read_loop
19b0185
@neyberson
Add loop verification in some methods about subscriptions
4151c9b
@neyberson
Add subscribe_once() in target.py
0645a93
@neyberson
Change some Error strings about subscriptions in Target
4587e0b
@neyberson
Delete hex() use in subscriptions_futures loop
cc47f01
@neyberson
Create _get_first_session() in target.py
b34a5a1
@neyberson
Simplify _get_first_session()
4712cee
@neyberson
Improve debugs for subscriptions_futures in run_read_loop()
83c82cd
@ayjayt
Lint
a94019a
@ayjayt
Merge pull request #36 from geopozo/andrew/process_control
ff9f91f 
Andrew/process control
@ayjayt ayjayt merged commit 70f00e6 into andrew/kaleido Sep 23, 2024
1 check failed
@ayjayt ayjayt deleted the neyberson/subscribe branch September 23, 2024 20:04
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
2 participants
@neyberson @ayjayt