from datetime import timedelta from django.utils import timezone import pytest from monitoring.models import Task from monitoring.ingest import ingest from tests.test_monitoring import server,auth,client,ev @pytest.mark.django_db def test_terminal_event_arriving_after_later_received(server): now=timezone.now() ingest(server.pk,[ev('task-received',{'uuid':'late'},now)]) ingest(server.pk,[ev('task-succeeded',{'uuid':'late','runtime':4},now-timedelta(seconds=1))]) assert Task.objects.get().state=='SUCCESS' @pytest.mark.django_db def test_old_flower_status_is_not_online(server,auth): ingest(server.pk,[ev('flower-status',{'online':True},timezone.now()-timedelta(hours=1))]) assert auth.get('/api/flower/').json()[0]['online'] is False