Style changes from review.

python/lsst/ap/association/association.py

@@ -234,7 +234,8 @@ def update_dia_objects(self,
                            diaSourceHistory,
                            updated_obj_ids,
                            exposure,
-                           apdb):
+                           apdb,
+                           ):
         """Update select dia_objects currently stored within the database or
         create new ones.
 

python/lsst/ap/association/diaCalculationPlugins.py

@@ -87,6 +87,8 @@ def calculate(self, diaObjects, diaSources, **kwargs):
             Summary objects to store values in.
         diaSources : `pandas.DataFrame` or `pandas.DataFrameGroupBy`
             Catalog of DiaSources summarized by this DiaObject.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         for outCol in self.outputCols:
             if outCol not in diaObjects.columns:
@@ -148,6 +150,8 @@ def calculate(self, diaObjects, diaObjectId, **kwargs):
             Summary objects to store values in and read ra/decl from.
         diaObjectId : `int`
             Id of the diaObject to update.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         sphPoint = geom.SpherePoint(
             diaObjects.at[diaObjectId, "ra"] * geom.degrees,
@@ -180,6 +184,8 @@ def calculate(self, diaObjects, diaSources, **kwargs):
         ----------
         diaObject : `dict`
             Summary object to store values in and read ra/decl from.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         diaObjects.loc[:, "nDiaSources"] = diaSources.diaObjectId.count()
 
@@ -212,6 +218,8 @@ def calculate(self, diaObjects, diaSources, **kwargs):
         ----------
         diaObject : `dict`
             Summary object to store values in and read ra/decl from.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         diaObjects.loc[:, "flags"] = diaSources.flags.any()
 
@@ -256,6 +264,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         meanName = "{}PSFluxMean".format(filterName)
         errName = "{}PSFluxMeanErr".format(filterName)
@@ -337,6 +347,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         pTileNames = []
         for tilePercent in self.config.percentiles:
@@ -392,6 +404,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         # Set "delta degrees of freedom (ddf)" to 1 to calculate the unbiased
         # estimator of scatter (i.e. 'N - 1' instead of 'N').
@@ -440,6 +454,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         meanName = "{}PSFluxMean".format(filterName)
 
@@ -492,6 +508,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         diaObjects.loc[:, "{}PSFluxMAD".format(filterName)] = \
             filterDiaSources.psFlux.apply(median_absolute_deviation,
@@ -538,6 +556,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         diaObjects.loc[:, "{}PSFluxSkew".format(filterName)] = \
             filterDiaSources.psFlux.skew()
@@ -583,6 +603,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         minName = "{}PSFluxMin".format(filterName)
         if minName not in diaObjects.columns:
@@ -635,6 +657,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
 
         def _maxSlope(df):
@@ -692,6 +716,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         diaObjects.loc[:, "{}PSFluxErrMean".format(filterName)] = \
             filterDiaSources.psFluxErr.mean()
@@ -737,6 +763,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
 
         mName = "{}PSFluxLinearSlope".format(filterName)
@@ -804,6 +832,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         meanName = "{}PSFluxMean".format(filterName)
 
@@ -956,6 +986,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         totMeanName = "{}TOTFluxMean".format(filterName)
         if totMeanName not in diaObjects.columns:
@@ -1019,6 +1051,8 @@ def calculate(self,
             diaObject that are observed in the band pass ``filterName``.
         filterName : `str`
             Simple, string name of the filter for the flux being calculated.
+        **kwargs
+            Any additional keyword arguments that may be passed to the plugin.
         """
         # Set "delta degrees of freedom (ddf)" to 1 to calculate the unbiased
         # estimator of scatter (i.e. 'N - 1' instead of 'N').