some msgspec improvements

Author: CamDavidsonPilon

core/pioreactor/automations/events.py

@@ -2,37 +2,37 @@
 from pioreactor.structs import AutomationEvent
 
 
-class NoEvent(AutomationEvent):
+class NoEvent(AutomationEvent, tag="NoEvent"):
     pass
 
 
-class DilutionEvent(AutomationEvent):
+class DilutionEvent(AutomationEvent, tag="DilutionEvent"):
     pass
 
 
-class DosingStarted(AutomationEvent):
+class DosingStarted(AutomationEvent, tag="DosingStarted"):
     pass
 
 
-class DosingStopped(AutomationEvent):
+class DosingStopped(AutomationEvent, tag="DosingStopped"):
     pass
 
 
-class AddMediaEvent(AutomationEvent):
+class AddMediaEvent(AutomationEvent, tag="AddMediaEvent"):
     pass
 
 
-class AddAltMediaEvent(AutomationEvent):
+class AddAltMediaEvent(AutomationEvent, tag="AddAltMediaEvent"):
     pass
 
 
-class ChangedLedIntensity(AutomationEvent):
+class ChangedLedIntensity(AutomationEvent, tag="ChangedLedIntensity"):
     pass
 
 
-class ErrorOccurred(AutomationEvent):
+class ErrorOccurred(AutomationEvent, tag="ErrorOccurred"):
     pass
 
 
-class UpdatedHeaterDC(AutomationEvent):
+class UpdatedHeaterDC(AutomationEvent, tag="UpdatedHeaterDC"):
     pass

core/pioreactor/background_jobs/leader/mqtt_to_db_streaming.py

@@ -12,6 +12,7 @@
 from pioreactor import exc
 from pioreactor import structs
 from pioreactor import types as pt
+from pioreactor.automations import events as automation_events  # noqa: F401
 from pioreactor.background_jobs.base import LongRunningBackgroundJob
 from pioreactor.config import config
 from pioreactor.hardware import get_pwm_to_pin_map