Unverified Commit 89a6fd29 authored by Tao Feng's avatar Tao Feng Committed by GitHub

chore: apply license headers to all the source files (#304)

* chore: apply license headers to all the source files

* fix flake8 with autopep8

* fix more lint
parent 496ddfe6
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import abc import abc
import six import six
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import abc import abc
import logging import logging
import six import six
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from collections import namedtuple from collections import namedtuple
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import json import json
import logging import logging
from collections import namedtuple from collections import namedtuple
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import abc import abc
from pyhocon import ConfigTree # noqa: F401 from pyhocon import ConfigTree # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from collections import namedtuple from collections import namedtuple
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from collections import namedtuple from collections import namedtuple
from datetime import date, timedelta from datetime import date, timedelta
import logging import logging
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from collections import namedtuple from collections import namedtuple
import logging import logging
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from cassandra.cluster import Cluster from cassandra.cluster import Cluster
from pyhocon import ConfigFactory, ConfigTree # noqa: F401 from pyhocon import ConfigFactory, ConfigTree # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import csv import csv
import importlib import importlib
from collections import defaultdict from collections import defaultdict
...@@ -16,6 +19,7 @@ class CsvExtractor(Extractor): ...@@ -16,6 +19,7 @@ class CsvExtractor(Extractor):
""" """
An Extractor that extracts records via CSV. An Extractor that extracts records via CSV.
""" """
def init(self, conf): def init(self, conf):
# type: (ConfigTree) -> None # type: (ConfigTree) -> None
""" """
...@@ -73,6 +77,7 @@ class CsvTableColumnExtractor(Extractor): ...@@ -73,6 +77,7 @@ class CsvTableColumnExtractor(Extractor):
""" """
An Extractor that combines Table and Column CSVs. An Extractor that combines Table and Column CSVs.
""" """
def init(self, conf): def init(self, conf):
# type: (ConfigTree) -> None # type: (ConfigTree) -> None
""" """
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from pyhocon import ConfigTree, ConfigFactory # noqa: F401 from pyhocon import ConfigTree, ConfigFactory # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
ORGANIZATION = 'organization' ORGANIZATION = 'organization'
MODE_ACCESS_TOKEN = 'mode_user_token' MODE_ACCESS_TOKEN = 'mode_user_token'
MODE_PASSWORD_TOKEN = 'mode_password_token' MODE_PASSWORD_TOKEN = 'mode_password_token'
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from pyhocon import ConfigTree, ConfigFactory # noqa: F401 from pyhocon import ConfigTree, ConfigFactory # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from pyhocon import ConfigTree, ConfigFactory # noqa: F401 from pyhocon import ConfigTree, ConfigFactory # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from pyhocon import ConfigTree, ConfigFactory # noqa: F401 from pyhocon import ConfigTree, ConfigFactory # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from pyhocon import ConfigTree, ConfigFactory # noqa: F401 from pyhocon import ConfigTree, ConfigFactory # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from pyhocon import ConfigTree, ConfigFactory # noqa: F401 from pyhocon import ConfigTree, ConfigFactory # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from pyhocon import ConfigTree, ConfigFactory # noqa: F401 from pyhocon import ConfigTree, ConfigFactory # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from pyhocon import ConfigTree # noqa: F401 from pyhocon import ConfigTree # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from typing import Any # noqa: F401 from typing import Any # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from pyhocon import ConfigTree, ConfigFactory # noqa: F401 from pyhocon import ConfigTree, ConfigFactory # noqa: F401
from requests.auth import HTTPBasicAuth from requests.auth import HTTPBasicAuth
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import importlib import importlib
from pyhocon import ConfigFactory from pyhocon import ConfigFactory
from databuilder.models.dashboard.dashboard_metadata import DashboardMetadata from databuilder.models.dashboard.dashboard_metadata import DashboardMetadata
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from databuilder.rest_api.rest_api_query import RestApiQuery from databuilder.rest_api.rest_api_query import RestApiQuery
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
import six import six
from collections import namedtuple from collections import namedtuple
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import importlib import importlib
import logging import logging
from typing import Iterable, Any # noqa: F401 from typing import Iterable, Any # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from collections import namedtuple from collections import namedtuple
import textwrap import textwrap
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import importlib import importlib
from typing import Iterable, Any # noqa: F401 from typing import Iterable, Any # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import boto3 import boto3
from pyhocon import ConfigFactory, ConfigTree # noqa: F401 from pyhocon import ConfigFactory, ConfigTree # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
import time import time
from datetime import datetime from datetime import datetime
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from collections import namedtuple from collections import namedtuple
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from datetime import datetime, timedelta from datetime import datetime, timedelta
import importlib import importlib
import logging import logging
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
import six import six
from collections import namedtuple from collections import namedtuple
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
import six import six
from collections import namedtuple from collections import namedtuple
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import importlib import importlib
import time import time
from typing import Iterable, Any # noqa: F401 from typing import Iterable, Any # noqa: F401
...@@ -11,6 +14,7 @@ class Neo4jEsLastUpdatedExtractor(GenericExtractor): ...@@ -11,6 +14,7 @@ class Neo4jEsLastUpdatedExtractor(GenericExtractor):
""" """
Extractor to extract last updated timestamp for neo4j and Es Extractor to extract last updated timestamp for neo4j and Es
""" """
def init(self, conf): def init(self, conf):
# type: (ConfigTree) -> None # type: (ConfigTree) -> None
""" """
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import importlib import importlib
import logging import logging
from typing import Any, Iterator, Union # noqa: F401 from typing import Any, Iterator, Union # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import textwrap import textwrap
from typing import Any # noqa: F401 from typing import Any # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
import six import six
from collections import namedtuple from collections import namedtuple
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import base64 import base64
import json import json
import logging import logging
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
import importlib import importlib
from typing import Iterator, Any # noqa: F401 from typing import Iterator, Any # noqa: F401
...@@ -41,7 +44,6 @@ class RestAPIExtractor(Extractor): ...@@ -41,7 +44,6 @@ class RestAPIExtractor(Extractor):
def extract(self): def extract(self):
# type: () -> Any # type: () -> Any
""" """
Fetch one result row from RestApiQuery, convert to {model_class} if specified before Fetch one result row from RestApiQuery, convert to {model_class} if specified before
returning. returning.
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
import six import six
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import importlib import importlib
from sqlalchemy import create_engine from sqlalchemy import create_engine
...@@ -14,6 +17,7 @@ class SQLAlchemyExtractor(Extractor): ...@@ -14,6 +17,7 @@ class SQLAlchemyExtractor(Extractor):
""" """
An Extractor that extracts records via SQLAlchemy. Database that supports SQLAlchemy can use this extractor An Extractor that extracts records via SQLAlchemy. Database that supports SQLAlchemy can use this extractor
""" """
def init(self, conf): def init(self, conf):
# type: (ConfigTree) -> None # type: (ConfigTree) -> None
""" """
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from pyhocon import ConfigFactory, ConfigTree # noqa: F401 from pyhocon import ConfigFactory, ConfigTree # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from datetime import datetime # noqa: F401 from datetime import datetime # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import abc import abc
from pyhocon import ConfigTree # noqa: F401 from pyhocon import ConfigTree # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from pyhocon import ConfigTree # noqa: F401 from pyhocon import ConfigTree # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import abc import abc
from pyhocon import ConfigTree # noqa: F401 from pyhocon import ConfigTree # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import csv import csv
import logging import logging
...@@ -11,6 +14,7 @@ class FileSystemCSVLoader(Loader): ...@@ -11,6 +14,7 @@ class FileSystemCSVLoader(Loader):
""" """
Loader class to write csv files to Local FileSystem Loader class to write csv files to Local FileSystem
""" """
def init(self, conf): def init(self, conf):
# type: (ConfigTree) -> None # type: (ConfigTree) -> None
""" """
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import os import os
from pyhocon import ConfigTree # noqa: F401 from pyhocon import ConfigTree # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import six import six
import logging import logging
import os import os
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from pyhocon import ConfigTree # noqa: F401 from pyhocon import ConfigTree # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import Any, Dict, List, Union # noqa: F401 from typing import Any, Dict, List, Union # noqa: F401
from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \ from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
CLUSTER_NODE_LABEL = 'Cluster' CLUSTER_NODE_LABEL = 'Cluster'
CLUSTER_RELATION_TYPE = 'CLUSTER' CLUSTER_RELATION_TYPE = 'CLUSTER'
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import Union, Dict, Any, Iterator # noqa: F401 from typing import Union, Dict, Any, Iterator # noqa: F401
from databuilder.models.neo4j_csv_serde import ( from databuilder.models.neo4j_csv_serde import (
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from typing import Optional, Dict, Any, Union, Iterator # noqa: F401 from typing import Optional, Dict, Any, Union, Iterator # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from typing import Optional, Dict, Any, Union, Iterator # noqa: F401 from typing import Optional, Dict, Any, Union, Iterator # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from typing import Optional, Dict, Any, Union, Iterator # noqa: F401 from typing import Optional, Dict, Any, Union, Iterator # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from collections import namedtuple from collections import namedtuple
from typing import Any, Union, Iterator, Dict, Set, Optional # noqa: F401 from typing import Any, Union, Iterator, Dict, Set, Optional # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from typing import Optional, Dict, Any, Union, Iterator # noqa: F401 from typing import Optional, Dict, Any, Union, Iterator # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from typing import Optional, Dict, Any, Union, Iterator # noqa: F401 from typing import Optional, Dict, Any, Union, Iterator # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
import re import re
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import logging import logging
from typing import Optional, Dict, Any, Union, Iterator # noqa: F401 from typing import Optional, Dict, Any, Union, Iterator # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import List, Optional # noqa: F401 from typing import List, Optional # noqa: F401
from databuilder.models.elasticsearch_document import ElasticsearchDocument from databuilder.models.elasticsearch_document import ElasticsearchDocument
...@@ -7,6 +10,7 @@ class DashboardESDocument(ElasticsearchDocument): ...@@ -7,6 +10,7 @@ class DashboardESDocument(ElasticsearchDocument):
""" """
Schema for the ES dashboard ES document Schema for the ES dashboard ES document
""" """
def __init__(self, def __init__(self,
group_name, # type: str group_name, # type: str
name, # type: str name, # type: str
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import json import json
from abc import ABCMeta from abc import ABCMeta
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import List, Optional # noqa: F401 from typing import List, Optional # noqa: F401
from databuilder.models.elasticsearch_document import ElasticsearchDocument from databuilder.models.elasticsearch_document import ElasticsearchDocument
...@@ -7,6 +10,7 @@ class MetricESDocument(ElasticsearchDocument): ...@@ -7,6 +10,7 @@ class MetricESDocument(ElasticsearchDocument):
""" """
Schema for the Search index document Schema for the Search index document
""" """
def __init__(self, def __init__(self,
name, # type: str name, # type: str
description, # type: str description, # type: str
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from collections import namedtuple from collections import namedtuple
from typing import Iterable, Any, Union, Iterator, Dict, Set # noqa: F401 from typing import Iterable, Any, Union, Iterator, Dict, Set # noqa: F401
...@@ -147,9 +150,9 @@ class MetricMetadata(Neo4jCsvSerializable): ...@@ -147,9 +150,9 @@ class MetricMetadata(Neo4jCsvSerializable):
# Metric type node # Metric type node
if self.type: if self.type:
yield {NODE_LABEL: MetricMetadata.METRIC_TYPE_NODE_LABEL, yield {NODE_LABEL: MetricMetadata.METRIC_TYPE_NODE_LABEL,
NODE_KEY: self._get_metric_type_key(), NODE_KEY: self._get_metric_type_key(),
'name': self.type} 'name': self.type}
others = [] others = []
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import abc import abc
import six import six
...@@ -29,6 +32,7 @@ class Neo4jCsvSerializable(object): ...@@ -29,6 +32,7 @@ class Neo4jCsvSerializable(object):
Any model class that needs to be pushed to Neo4j should inherit this class. Any model class that needs to be pushed to Neo4j should inherit this class.
""" """
def __init__(self): def __init__(self):
# type: () -> None # type: () -> None
pass pass
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import Any, Dict, List, Union # noqa: F401 from typing import Any, Dict, List, Union # noqa: F401
from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, NODE_LABEL from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, NODE_LABEL
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
OWNER_RELATION_TYPE = 'OWNER' OWNER_RELATION_TYPE = 'OWNER'
OWNER_OF_OBJECT_RELATION_TYPE = 'OWNER_OF' OWNER_OF_OBJECT_RELATION_TYPE = 'OWNER_OF'
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
class PrestoQueryLogs: class PrestoQueryLogs:
""" """
Presto Query logs model. Presto Query logs model.
Sql result has one row per presto query. Sql result has one row per presto query.
""" """
def __init__(self, def __init__(self,
user, # type: str user, # type: str
query_text, # type: str query_text, # type: str
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import Dict, Any, Union, Iterator # noqa: F401 from typing import Dict, Any, Union, Iterator # noqa: F401
from databuilder.models.neo4j_csv_serde import ( from databuilder.models.neo4j_csv_serde import (
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
SCHEMA_NODE_LABEL = 'Schema' SCHEMA_NODE_LABEL = 'Schema'
SCHEMA_NAME_ATTR = 'name' SCHEMA_NAME_ATTR = 'name'
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import Iterable, Union, Dict, Any, Iterator # noqa: F401 from typing import Iterable, Union, Dict, Any, Iterator # noqa: F401
from databuilder.models.neo4j_csv_serde import ( from databuilder.models.neo4j_csv_serde import (
...@@ -13,6 +16,7 @@ class ColumnReader(object): ...@@ -13,6 +16,7 @@ class ColumnReader(object):
""" """
A class represent user's read action on column. Implicitly assumes that read count is one. A class represent user's read action on column. Implicitly assumes that read count is one.
""" """
def __init__(self, def __init__(self,
database, # type: str database, # type: str
cluster, # type: str cluster, # type: str
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import List, Optional # noqa: F401 from typing import List, Optional # noqa: F401
from databuilder.models.elasticsearch_document import ElasticsearchDocument from databuilder.models.elasticsearch_document import ElasticsearchDocument
...@@ -7,6 +10,7 @@ class TableESDocument(ElasticsearchDocument): ...@@ -7,6 +10,7 @@ class TableESDocument(ElasticsearchDocument):
""" """
Schema for the Search index document Schema for the Search index document
""" """
def __init__(self, def __init__(self,
database, # type: str database, # type: str
cluster, # type: str cluster, # type: str
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import Any, Dict, List, Union # noqa: F401 from typing import Any, Dict, List, Union # noqa: F401
from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \ from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import re import re
from typing import Any, Dict, List, Union # noqa: F401 from typing import Any, Dict, List, Union # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import copy import copy
from collections import namedtuple from collections import namedtuple
from six import string_types from six import string_types
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import Any, Dict, List, Union # noqa: F401 from typing import Any, Dict, List, Union # noqa: F401
from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \ from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import Any, Dict, List, Union # noqa: F401 from typing import Any, Dict, List, Union # noqa: F401
from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \ from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import Any, Dict, List, Union # noqa: F401 from typing import Any, Dict, List, Union # noqa: F401
from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \ from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from enum import Enum from enum import Enum
NODE_LABEL = 'Timestamp' NODE_LABEL = 'Timestamp'
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from databuilder.publisher.neo4j_csv_publisher import UNQUOTED_SUFFIX from databuilder.publisher.neo4j_csv_publisher import UNQUOTED_SUFFIX
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
import copy import copy
from typing import Union, Dict, Any # noqa: F401 from typing import Union, Dict, Any # noqa: F401
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from databuilder.models.elasticsearch_document import ElasticsearchDocument from databuilder.models.elasticsearch_document import ElasticsearchDocument
...@@ -5,6 +8,7 @@ class UserESDocument(ElasticsearchDocument): ...@@ -5,6 +8,7 @@ class UserESDocument(ElasticsearchDocument):
""" """
Schema for the Search index document for user Schema for the Search index document for user
""" """
def __init__(self, def __init__(self,
email, # type: str email, # type: str
first_name, # type: str first_name, # type: str
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
from typing import Any, Dict, List, Union # noqa: F401 from typing import Any, Dict, List, Union # noqa: F401
from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \ from databuilder.models.neo4j_csv_serde import Neo4jCsvSerializable, NODE_KEY, \
......
# Copyright Contributors to the Amundsen project.
# SPDX-License-Identifier: Apache-2.0
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment