Skip to content

Commit

Permalink
Fix typehint-remover and enforce black (#162)
Browse files Browse the repository at this point in the history
* Run typehint-remover before running tests

* Update type_hint_remover to use strip-hints package

* Run new type_hint_remover in Jenkins

* Require python version >= 3.5

* Remove unnecessary class scope variables in v06 dtos

* Simplify type_hint_remover

* Enforce black (#163)

* Bump version to 0.11.19
  • Loading branch information
Erlend Vollset committed Nov 27, 2018
1 parent d184d7c commit 21f950f
Show file tree
Hide file tree
Showing 30 changed files with 400 additions and 461 deletions.
6 changes: 6 additions & 0 deletions .pre-commit-config.yaml
@@ -0,0 +1,6 @@
repos:
- repo: https://github.com/cognitedata/python-pre-commit-hooks
rev: e2944b2
hooks:
- id: isort
- id: black
7 changes: 5 additions & 2 deletions Jenkinsfile
Expand Up @@ -49,6 +49,11 @@ podTemplate(
stage('Install dependencies') {
sh("pipenv sync --dev")
}
stage('Check code style & remove typehints') {
sh("pipenv run black -l 120 --check .")
sh("pipenv run python3 type_hint_remover.py")
sh("pipenv run python3 -m black ./cognite -l 120")
}
stage('Test and coverage report') {
sh("pipenv run pytest --cov-report xml:coverage.xml --cov=cognite --junitxml=test-report.xml || true")
junit(allowEmptyResults: true, testResults: '**/test-report.xml')
Expand All @@ -59,8 +64,6 @@ podTemplate(
step([$class: 'CoberturaPublisher', coberturaReportFile: 'coverage.xml'])
}
stage('Build') {
sh("pipenv run python3 code_parser.py --remove-type-hints --suppress-warning")
sh("pipenv run python3 -m black ./cognite -l 120")
sh("python3 setup.py sdist")
sh("python3 setup.py bdist_wheel")
}
Expand Down
4 changes: 3 additions & 1 deletion Pipfile
Expand Up @@ -20,7 +20,9 @@ twine = "*"
pytest = "*"
pylint = "*"
astunparse = "*"
black = "*"
black = "==18.6b4"
strip-hints = "*"
pre-commit = "*"

[requires]
python_version = "3.6"
Expand Down
213 changes: 162 additions & 51 deletions Pipfile.lock

Large diffs are not rendered by default.

66 changes: 0 additions & 66 deletions code_parser.py

This file was deleted.

2 changes: 1 addition & 1 deletion cognite/__init__.py
Expand Up @@ -18,4 +18,4 @@
#

__all__ = ["v04", "v05", "v06", "preprocessing", "config", "data_transfer_service"]
__version__ = "0.11.18"
__version__ = "0.11.19"
1 change: 1 addition & 0 deletions cognite/_utils.py
Expand Up @@ -32,6 +32,7 @@ def serialize(obj):
"""JSON serializer for objects not serializable by default json code"""
return obj.__dict__


def _raise_API_error(res):
x_request_id = res.headers.get("X-Request-Id")
code = res.status_code
Expand Down
1 change: 1 addition & 0 deletions cognite/auxiliary/_hosting/model/model/model.py
Expand Up @@ -2,6 +2,7 @@

from cognite.data_transfer_service import DataTransferService


class Model:
def __init__(self, model):
self._model = model
Expand Down
8 changes: 2 additions & 6 deletions cognite/v04/raw.py
Expand Up @@ -228,9 +228,7 @@ def create_rows(
"""
api_key, project = config.get_config_variables(api_key, project)
url = config.get_base_url() + "/api/0.4/projects/{}/raw/{}/{}/create".format(
project, database_name, table_name
)
url = config.get_base_url() + "/api/0.4/projects/{}/raw/{}/{}/create".format(project, database_name, table_name)

headers = {"api-key": api_key, "content-type": "*/*", "accept": "application/json"}
if ensure_parent:
Expand Down Expand Up @@ -270,9 +268,7 @@ def delete_rows(
"""
api_key, project = config.get_config_variables(api_key, project)
url = config.get_base_url() + "/api/0.4/projects/{}/raw/{}/{}/delete".format(
project, database_name, table_name
)
url = config.get_base_url() + "/api/0.4/projects/{}/raw/{}/{}/delete".format(project, database_name, table_name)
body = {"items": [{"key": "{}".format(row.key), "columns": row.columns} for row in rows]}
headers = {"api-key": api_key, "content-type": "*/*", "accept": "application/json"}
res = _utils.post_request(url=url, body=body, headers=headers, cookies=config.get_cookies())
Expand Down
12 changes: 3 additions & 9 deletions cognite/v04/timeseries.py
Expand Up @@ -152,9 +152,7 @@ def _get_datapoints_helper(tag_id, aggregates=None, granularity=None, start=None
list of datapoints: A list containing datapoint dicts.
"""
api_key, project = kwargs.get("api_key"), kwargs.get("project")
url = config.get_base_url() + "/api/0.4/projects/{}/timeseries/data/{}".format(
project, quote(tag_id, safe="")
)
url = config.get_base_url() + "/api/0.4/projects/{}/timeseries/data/{}".format(project, quote(tag_id, safe=""))

use_protobuf = kwargs.get("protobuf", True) and aggregates is None
limit = _constants.LIMIT if aggregates is None else _constants.LIMIT_AGG
Expand Down Expand Up @@ -274,9 +272,7 @@ def post_datapoints(tag_id, datapoints: List[Datapoint], **kwargs):
An empty response.
"""
api_key, project = config.get_config_variables(kwargs.get("api_key"), kwargs.get("project"))
url = config.get_base_url() + "/api/0.4/projects/{}/timeseries/data/{}".format(
project, quote(tag_id, safe="")
)
url = config.get_base_url() + "/api/0.4/projects/{}/timeseries/data/{}".format(project, quote(tag_id, safe=""))

headers = {"api-key": api_key, "content-type": "application/json", "accept": "application/json"}

Expand Down Expand Up @@ -305,9 +301,7 @@ def get_latest(tag_id, **kwargs):
output formats.
"""
api_key, project = config.get_config_variables(kwargs.get("api_key"), kwargs.get("project"))
url = config.get_base_url() + "/api/0.4/projects/{}/timeseries/latest/{}".format(
project, quote(tag_id, safe="")
)
url = config.get_base_url() + "/api/0.4/projects/{}/timeseries/latest/{}".format(project, quote(tag_id, safe=""))
headers = {"api-key": api_key, "accept": "application/json"}
res = _utils.get_request(url, headers=headers, cookies=config.get_cookies())
return LatestDatapointResponse(res.json())
Expand Down
8 changes: 2 additions & 6 deletions cognite/v05/raw.py
Expand Up @@ -228,9 +228,7 @@ def create_rows(
"""
api_key, project = config.get_config_variables(api_key, project)
url = config.get_base_url() + "/api/0.5/projects/{}/raw/{}/{}/create".format(
project, database_name, table_name
)
url = config.get_base_url() + "/api/0.5/projects/{}/raw/{}/{}/create".format(project, database_name, table_name)

headers = {"api-key": api_key, "content-type": "*/*", "accept": "application/json"}
if ensure_parent:
Expand Down Expand Up @@ -270,9 +268,7 @@ def delete_rows(
"""
api_key, project = config.get_config_variables(api_key, project)
url = config.get_base_url() + "/api/0.5/projects/{}/raw/{}/{}/delete".format(
project, database_name, table_name
)
url = config.get_base_url() + "/api/0.5/projects/{}/raw/{}/{}/delete".format(project, database_name, table_name)
body = {"items": [{"key": "{}".format(row.key), "columns": row.columns} for row in rows]}
headers = {"api-key": api_key, "content-type": "*/*", "accept": "application/json"}
res = _utils.post_request(url=url, body=body, headers=headers, cookies=config.get_cookies())
Expand Down

0 comments on commit 21f950f

Please sign in to comment.