b9ef69a865
Refactor OpcManager initialization and unsubscribe method; enhance logging - Removed the `initialize_from_config` method from `OpcManager` class and adjusted the constructor to handle configuration directly. - Improved the `unsubscribe` method to include detailed logging for non-existent subscriptions. - Updated tests in `test_opc_manager.py` to reflect changes in the `OpcManager` class. - Commented out Docker-related fixtures in `conftest.py` for potential future use. - Enhanced test coverage in `test_single_node.py` and `test_data_manager.py` with additional scenarios and assertions. - Introduced new methods in `Ingestor` and `IngestorManager` classes to manage server subscriptions and leases more effectively. - Added new tests for `Ingestor` class to validate initialization and slot management logic. - Implemented logging improvements across various classes to ensure better traceability of actions and errors.
20 lines
290 B
Python
20 lines
290 B
Python
from time import sleep
|
|
from ingestor.ingestor import Ingestor
|
|
|
|
|
|
def main():
|
|
ingestor = Ingestor()
|
|
|
|
ingestor.prepare_ingestor()
|
|
|
|
while True:
|
|
|
|
ingestor.loop()
|
|
|
|
# Sleep for poll interval
|
|
sleep(ingestor.poll_interval)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|