appease the line length gods

Author: Jon

tom_dataproducts/alertstreams/hermes_ingester.py

@@ -78,7 +78,8 @@ def hermes_alert_handler(alert, metadata):
     def resolve_target(target_name):
         if target_name not in target_cache:
             # We first attempt to match to an existing target in the TOM by target_name or any specified aliases
-            target_entry = next((t for t in target_table if t.get('name', '') == target_name), {}) if target_table else {}
+            target_entry = next((t for t in target_table if t.get('name', '')
+                                == target_name), {}) if target_table else {}
             aliases = target_entry.get('aliases', [])
             query = Target.matches.match_name(target_name)
             if not query:
@@ -195,15 +196,17 @@ def _ingest_hermes_spectroscopy_file(url, spectroscopy_row, target, hermes_alert
     spectroscopy_keys = ['date_obs', 'flux_units', 'wavelength_units', 'telescope', 'instrument', 'reducer',
                          'observer', 'spec_type', 'flux_type', 'classification', 'comments', 'exposure_time',
                          'setup', 'proprietary_period', 'proprietary_period_units']
-    spectroscopy_data = {key: spectroscopy_row[key] for key in spectroscopy_keys if key in spectroscopy_row and spectroscopy_row[key]}
+    spectroscopy_data = {key: spectroscopy_row[key]
+                         for key in spectroscopy_keys if key in spectroscopy_row and spectroscopy_row[key]}
     # Inject these two extra fields since they should be associated with the ReducedDatums somehow
     spectroscopy_data['source_name'] = hermes_alert.topic
     spectroscopy_data['source_location'] = alert_url
 
     try:
         dp, created = DataProduct.objects.get_or_create(
             product_id=url,
-            defaults={'target': target, 'data_product_type': 'spectroscopy', 'extra_data': json.dumps(spectroscopy_data)},
+            defaults={'target': target, 'data_product_type': 'spectroscopy',
+                      'extra_data': json.dumps(spectroscopy_data)},
         )
         if created:
             _, ext = os.path.splitext(filename)

tom_dataproducts/alertstreams/hermes_publisher.py

@@ -8,8 +8,6 @@
 from tom_alerts.models import AlertStreamMessage
 from tom_targets.models import Target
 
-
-
 logger = logging.getLogger(__name__)
 logger.setLevel(logging.DEBUG)
 
@@ -292,5 +290,3 @@ def get_hermes_topics(**kwargs):
         except (KeyError, requests.exceptions.JSONDecodeError):
             pass
     return topics
-
-

tom_dataproducts/templatetags/dataproduct_extras.py

@@ -390,7 +390,8 @@ def spectroscopy_for_target(context, target, dataproduct=None):
     else:
         datums = get_objects_for_user(context['request'].user,
                                       'tom_dataproducts.view_reduceddatum',
-                                      klass=ReducedDatum.objects.filter(target=target, data_type=spectroscopy_data_type))
+                                      klass=ReducedDatum.objects.filter(target=target,
+                                                                        data_type=spectroscopy_data_type))
 
     # If a dataproduct is specified, filter on that specific dataproduct
     if dataproduct:

tom_dataproducts/tests/test_sharing.py

@@ -1,6 +1,7 @@
 from django.test import TestCase, override_settings
 
-from tom_dataproducts.alertstreams.hermes_publisher import create_hermes_alert, BuildHermesMessage, HermesMessageException
+from tom_dataproducts.alertstreams.hermes_publisher import (create_hermes_alert, BuildHermesMessage,
+                                                            HermesMessageException)
 from tom_dataproducts.models import ReducedDatum
 from tom_observations.tests.utils import FakeRoboticFacility
 from tom_observations.tests.factories import SiderealTargetFactory, ObservingRecordFactory