this works

requirements.txt

@@ -12,3 +12,4 @@ tom-antares
 tom-fink
 antares-client==1.1
 fink-client~=2.0
+tom-pittgoogle==0.1.6

stream/models.py

@@ -34,7 +34,6 @@ class EventAttributes(models.Model):
     created = models.DateTimeField(auto_now_add=True)
     modified = models.DateTimeField(auto_now=True)
 
-
 class Alert(models.Model):
     # target_id = models.ForeignKey(Target, on_delete=models.CASCADE)
     topic = models.ForeignKey(Topic, on_delete=models.PROTECT)
@@ -52,3 +51,21 @@ class Meta:
         indexes = [
             models.Index(fields=['timestamp'], name='timestamp_idx'),
         ]
+
+# class ElasticcAlert(models.Model):
+#     # target_id = models.ForeignKey(Target, on_delete=models.CASCADE)
+#     topic = models.ForeignKey(Topic, on_delete=models.PROTECT)
+#     events = models.ManyToManyField(Event)
+#     identifier = models.CharField(max_length=200)
+#     timestamp = models.DateTimeField(null=True, blank=True)
+#     coordinates = gis_models.PointField(null=True, blank=True)
+#     parsed_message = models.JSONField(default=dict)
+#     raw_message = models.JSONField(default=dict)
+#     parsed = models.BooleanField(default=False)
+#     created = models.DateTimeField(auto_now_add=True)
+#     modified = models.DateTimeField(auto_now=True)
+#
+#     class Meta:
+#         indexes = [
+#             models.Index(fields=['timestamp'], name='timestamp_idx'),
+#         ]

tom_desc/settings.py

@@ -330,7 +330,7 @@
     'tom_alerts.brokers.scout.ScoutBroker',
     'tom_alerts.brokers.tns.TNSBroker',
     'tom_fink.fink.FinkBroker',
-    'tom_pittgoogle.pittgoogle.PittGoogleBroker',
+    'tom_pittgoogle.broker_stream_rest.BrokerStreamRest',
 ]
 
 BROKERS = {