Merge pull request #287 from cmu-delphi/sir-dryrun

[sir-complainsalot] Add grace period and dry run

Author: krivard

sir_complainsalot/delphi_sir_complainsalot/check_source.py

@@ -26,7 +26,7 @@ def to_md(self):
             source=self.data_source, signal=self.signal, geos=", ".join(self.geo_types),
             message=self.message, updated=self.last_updated.strftime("%Y-%m-%d"))
 
-def check_source(data_source, meta, params):
+def check_source(data_source, meta, params, grace):
     """Iterate over all signals from a source and check if they exceed max age."""
 
     source_config = params[data_source]
@@ -44,7 +44,7 @@ def check_source(data_source, meta, params):
 
         age = (now - row["max_time"]).days
 
-        if age > source_config["max_age"]:
+        if age > source_config["max_age"] + grace:
             if row["signal"] not in complaints:
                 complaints[row["signal"]] = Complaint(
                     "is more than {age} days old".format(age=age),

sir_complainsalot/delphi_sir_complainsalot/run.py

@@ -22,7 +22,7 @@ def run_module():
 
     complaints = []
     for data_source in params["sources"].keys():
-        complaints.extend(check_source(data_source, meta, params["sources"]))
+        complaints.extend(check_source(data_source, meta, params["sources"], params.get("grace",0)))
 
     if len(complaints) > 0:
         for complaint in complaints:
@@ -34,6 +34,9 @@ def run_module():
 
 def report_complaints(complaints, params):
     """Post complaints to Slack."""
+    if not params["slack_token"]:
+        print("\b (dry-run)")
+        return
 
     blocks = format_complaints(complaints)