pass the test function names to the flagger

saqc/core/core.py

@@ -130,14 +130,14 @@ def runner(metafname, flagger, data, flags=None, nodata=np.nan):
             if Params.FLAGPERIOD in flag_params:
                 ffchunk = assignTypeSafe(
                     ffchunk, varname,
-                    flagPeriod(flagger, ffchunk[varname], mask, **flag_params))
+                    flagPeriod(flagger, ffchunk[varname], mask, func_name=func_name, **flag_params))
 
             # flag a certain amount of values after condition is met
             if Params.FLAGVALUES in flag_params:
                 ffchunk = assignTypeSafe(
                     ffchunk,
                     varname,
-                    flagNext(flagger, ffchunk[varname], mask, **flag_params))
+                    flagNext(flagger, ffchunk[varname], mask, func_name=func_name, **flag_params))
 
             if flag_params.get(Params.PLOT, False):
                 plotvars.append(varname)

saqc/flagger/dmpflagger.py

@@ -71,9 +71,6 @@ class DmpFlagger(BaseFlagger):
         flagcol = flags.loc[:, FlagFields.FLAG].squeeze()
         return super().isFlagged(flagcol, flag, comparator)
 
-    def _getCaller(self):
-        return inspect.stack()[1].function
-
     def _reduceColumns(self, flags):
         if set(flags.columns) == set(self.flag_fields):
             pass

saqc/funcs/functions.py

 #! /usr/bin/env python
 # -*- coding: utf-8 -*-
 
+import logging
+from functools import partial
+
 import numpy as np
 import pandas as pd
-import logging
 from scipy.signal import savgol_filter
 
 
@@ -26,8 +28,8 @@ FUNC_MAP = {}
 def register(name):
 
     def outer(func):
+        func = partial(func, func_name=name)
         FUNC_MAP[name] = func
-        func.__name__ = name
 
         def inner(*args, **kwargs):
             return func(*args, **kwargs)