diff --git a/ampel/lsst/alert/load/ElasticcTrainingsetLoader.py b/ampel/lsst/alert/load/ElasticcTrainingsetLoader.py index 42bc83a..81c6532 100644 --- a/ampel/lsst/alert/load/ElasticcTrainingsetLoader.py +++ b/ampel/lsst/alert/load/ElasticcTrainingsetLoader.py @@ -352,7 +352,14 @@ def __init__(self, **kwargs) -> None: ) if self.skip_transients != 0: - next(islice(self.lightcurves, self.skip_transients, self.skip_transients), None) + next( + islice( + self.lightcurves, + self.skip_transients, + self.skip_transients, + ), + None, + ) self.next_lightcurve() diff --git a/ampel/lsst/alert/load/KafkaAlertLoader.py b/ampel/lsst/alert/load/KafkaAlertLoader.py index 0bd183e..98a7bf4 100644 --- a/ampel/lsst/alert/load/KafkaAlertLoader.py +++ b/ampel/lsst/alert/load/KafkaAlertLoader.py @@ -30,9 +30,9 @@ class StaticSchemaURL(AmpelBaseModel): class SASLAuthentication(AmpelBaseModel): protocol: Literal["SASL_PLAINTEXT", "SASL_SSL"] = "SASL_PLAINTEXT" - mechanism: Literal[ - "PLAIN", "SCRAM-SHA-256", "SCRAM-SHA-512" - ] = "SCRAM-SHA-512" + mechanism: Literal["PLAIN", "SCRAM-SHA-256", "SCRAM-SHA-512"] = ( + "SCRAM-SHA-512" + ) username: NamedSecret[str] password: NamedSecret[str] diff --git a/ampel/lsst/alert/load/MultiAvroAlertLoader.py b/ampel/lsst/alert/load/MultiAvroAlertLoader.py index e8e6d88..b44337b 100644 --- a/ampel/lsst/alert/load/MultiAvroAlertLoader.py +++ b/ampel/lsst/alert/load/MultiAvroAlertLoader.py @@ -33,10 +33,10 @@ def __init__(self, **kwargs) -> None: self.set_alert_source(self.loader) def set_alert_source(self, loader) -> None: - self.alert_loader: AbsAlertLoader[ - Iterable[IOBase] - ] = AuxUnitRegister.new_unit( # type: ignore - model=loader + self.alert_loader: AbsAlertLoader[Iterable[IOBase]] = ( + AuxUnitRegister.new_unit( # type: ignore + model=loader + ) ) self.next_file() diff --git a/ampel/lsst/t0/SimpleLSSTFilter.py b/ampel/lsst/t0/SimpleLSSTFilter.py index 9e811c0..b80a53d 100644 --- a/ampel/lsst/t0/SimpleLSSTFilter.py +++ b/ampel/lsst/t0/SimpleLSSTFilter.py @@ -44,7 +44,9 @@ class SimpleLSSTFilter(CatalogMatchUnit, AbsAlertFilter): # Gaia gaia_rs: float # search radius for GAIA DR2 matching [arcsec] gaia_pm_signif: float # significance of proper motion detection of GAIA counterpart [sigma] - gaia_plx_signif: float # significance of parallax detection of GAIA counterpart [sigma] + gaia_plx_signif: ( + float # significance of parallax detection of GAIA counterpart [sigma] + ) gaia_veto_gmag_min: float # min gmag for normalized distance cut of GAIA counterparts [mag] gaia_veto_gmag_max: float # max gmag for normalized distance cut of GAIA counterparts [mag] gaia_excessnoise_sig_max: float # maximum allowed noise (expressed as significance) for Gaia match to be trusted.