cleanup

integrations/acquisition/covidcast/test_db.py

@@ -23,6 +23,7 @@ def _find_matches_for_row(self, row):
             cur.execute(q)
             res = cur.fetchone()
             if res:
+                # Create a dictionary of column names (from cursor.description) & values
                 results[table] = dict(zip([desc[0] for desc in cur.description], res))
             else:
                 results[table] = None

integrations/server/test_covidcast_endpoints.py

@@ -294,6 +294,7 @@ def test_backfill(self):
 
     def test_meta(self):
         """Request a signal from the /meta endpoint."""
+
         num_rows = 10
         rows = [CovidcastTestRow.make_default_row(time_value=2020_04_01 + i, value=i, source="fb-survey", signal="smoothed_cli") for i in range(num_rows)]
         self._insert_rows(rows)
@@ -343,6 +344,7 @@ def test_meta_restricted(self):
         #       by _load_data_signals() which attaches a list of signals to each source,
         #       in turn fed by src/server/endpoints/covidcast_utils/db_signals.csv)
         # insert data from two different sources, one restricted/protected (quidel), one not
+
         self._insert_rows([
             CovidcastTestRow.make_default_row(source="quidel", signal="raw_pct_negative"),
             CovidcastTestRow.make_default_row(source="hhs", signal="confirmed_admissions_covid_1d")

src/acquisition/covid_hosp/common/database.py

@@ -74,10 +74,10 @@ def connect(database_class, mysql_connector_impl=MySQLdb):
     # connect to the database
     user, password = secrets.db.epi
     connection = mysql_connector_impl.connect(
-      host=secrets.db.host,
-      user=user,
-      password=password,
-      database='epidata')
+        host=secrets.db.host,
+        user=user,
+        password=password,
+        database='epidata')
 
     try:
       # provide the connection to the context manager

src/acquisition/covidcast/database.py

@@ -100,6 +100,7 @@ def do_analyze(self):
       f'''ANALYZE TABLE
           signal_dim, geo_dim,
           {self.load_table}, {self.history_table}, {self.latest_table}''')
+    # Append lists of column names (from cursor.description) & values
     output = [desc[0] for desc in self._cursor.description] + list(self._cursor.fetchall())
     get_structured_logger('do_analyze').info("ANALYZE results", results=str(output))