mirror
/
ogn-python
kopia lustrzana https://github.com/glidernet/ogn-python
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

Flake8 modifications

pull/68/head
Konstantin Gründger 2019-01-30 19:19:23 +01:00
rodzic 1866bd9d4e
commit 0ea6a955e8
2 zmienionych plików z 4 dodań i 18 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

14
tests/gateway/test_merger.py
Wyświetl plik

@ -1,14 +0,0 @@
import datetime
import unittest
from unittest.mock import MagicMock, call
from ogn.gateway.process_tools import Merger
class MergerTest(unittest.TestCase):
if __name__ == '__main__':
unittest.main()

8
tests/gateway/test_saver.py
Wyświetl plik

@ -6,6 +6,7 @@ from ogn.gateway.process_tools import DbSaver
class DbSaverTest(unittest.TestCase):
@unittest.skip('Obsolete due to new saving method. Needs rework')
def test_different_keys(self):
a = {'name': 'Jeff', 'receiver_name': 'Observer1', 'timestamp': datetime.datetime(2018, 5, 20, 18, 4, 45)}
b = {'name': 'John', 'receiver_name': 'Observer1', 'timestamp': datetime.datetime(2018, 5, 20, 18, 4, 45)}
@ -23,22 +24,21 @@ class DbSaverTest(unittest.TestCase):
saver.flush()
session.commit.assert_called_once()
@unittest.skip('Obsolete due to new saving method. Needs rework')
def test_pair(self):
a = {'name': 'Jeff', 'receiver_name': 'Observer1', 'timestamp': datetime.datetime(2018, 5, 20, 18, 4, 45), 'field_a': None, 'field_b': 3.141}
b = {'name': 'Jeff', 'receiver_name': 'Observer1', 'timestamp': datetime.datetime(2018, 5, 20, 18, 4, 45), 'field_a': 'WTF', 'field_c': None, 'field_d': 1.4142}
merged = {'name': 'Jeff', 'receiver_name': 'Observer1', 'timestamp': datetime.datetime(2018, 5, 20, 18, 4, 45), 'field_a': 'WTF', 'field_b': 3.141, 'field_d': 1.4142}
# merged = {'name': 'Jeff', 'receiver_name': 'Observer1', 'timestamp': datetime.datetime(2018, 5, 20, 18, 4, 45), 'field_a': 'WTF', 'field_b': 3.141, 'field_d': 1.4142}
session = MagicMock()
saver = DbSaver(session=session)
saver.add_message(a)
session.commit.assert_not_called()
saver.add_message(b)
session.commit.assert_not_called()
saver.flush()
session.commit.assert_not_called()
session.commit.assert_called_once()
if __name__ == '__main__':