Fix PyLint + Flakes8

pygquery/BigQueryReader.py → pygquery/bigquery_reader.py

@@ -1,8 +1,16 @@
+"""BigQueryReader
+Reads a query
+"""
+
 from threading import Thread
 from google.cloud import bigquery
 from google.oauth2.service_account import Credentials
 
+
 class BigQueryReader(Thread):
+    """BigQueryReader
+    Reads a query
+    """
     def __init__(self, request, project, api_key_path):
         """Object Configuration"""
         Thread.__init__(self)
@@ -27,9 +35,10 @@ def __init__(self, request, project, api_key_path):
             raise RuntimeError(self._query_job.errors)
 
     def run(self):
-
+        """Start thread"""
         self._data = self._query_job.to_dataframe()
 
     @property
     def data(self):
+        """return data"""
         return self._data

pygquery/BigQueryWriter.py → pygquery/bigquery_writer.py

@@ -1,15 +1,19 @@
+"""BigQueryWriter
+Writes a query
+"""
+
 from threading import Thread
 from google.cloud import bigquery
 from google.oauth2.service_account import Credentials
 
-lass BigQueryWriter(Thread):
+
+class BigQueryWriter(Thread):
+    """Reads Query"""
     def __init__(self, dataframe, project, dataset, table, if_exists,
                  api_key_path):
         """Object Configuration"""
         Thread.__init__(self)
-        """Client Configuration"""
         credentials = Credentials.from_service_account_file(api_key_path)
-
         _client = bigquery.Client(credentials=credentials, project=project)
 
         dataset_ref = _client.dataset(dataset)
@@ -32,5 +36,5 @@ def __init__(self, dataframe, project, dataset, table, if_exists,
             job_config=_job_config)
 
     def run(self):
-
+        """starts writing data"""
         self._query_job.result()