File tree 23 files changed +336
-19
lines changed
23 files changed +336
-19
lines changed Original file line number Diff line number Diff line change
1
+ #
2
+ # Copyright 2024 Hopsworks AB
3
+ #
4
+ # Licensed under the Apache License, Version 2.0 (the "License");
5
+ # you may not use this file except in compliance with the License.
6
+ # You may obtain a copy of the License at
7
+ #
8
+ # http://www.apache.org/licenses/LICENSE-2.0
9
+ #
10
+ # Unless required by applicable law or agreed to in writing, software
11
+ # distributed under the License is distributed on an "AS IS" BASIS,
12
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ # See the License for the specific language governing permissions and
14
+ # limitations under the License.
15
+ #
16
+
17
+ from hopsworks_common .version import (
18
+ __version__ ,
19
+ )
20
+
21
+
22
+ __all__ = [
23
+ __version__ ,
24
+ ]
Original file line number Diff line number Diff line change 13
13
# See the License for the specific language governing permissions and
14
14
# limitations under the License.
15
15
#
16
+
16
17
from __future__ import annotations
17
18
18
19
import json
19
20
20
- from hsfs import util
21
+ from hopsworks_common import util
21
22
22
23
23
24
class Code :
Original file line number Diff line number Diff line change 13
13
# See the License for the specific language governing permissions and
14
14
# limitations under the License.
15
15
#
16
+
16
17
from __future__ import annotations
17
18
18
- from hsfs import client
19
+ from hopsworks_common import client
19
20
20
21
21
22
class CodeApi :
Original file line number Diff line number Diff line change 13
13
# See the License for the specific language governing permissions and
14
14
# limitations under the License.
15
15
#
16
+
16
17
from __future__ import annotations
17
18
18
19
import datetime
19
20
import os
20
21
21
- from hsfs import code
22
- from hsfs .core import code_api
22
+ from hopsworks_common import code
23
+ from hopsworks_common .core import code_api
23
24
24
25
25
26
class CodeEngine :
Original file line number Diff line number Diff line change 13
13
# See the License for the specific language governing permissions and
14
14
# limitations under the License.
15
15
#
16
+
16
17
from __future__ import annotations
17
18
18
19
from typing import Any , List
19
20
20
- from hsfs import client
21
+ from hopsworks_common import client
21
22
22
23
23
24
class HostsApi :
Original file line number Diff line number Diff line change 13
13
# See the License for the specific language governing permissions and
14
14
# limitations under the License.
15
15
#
16
+
16
17
from __future__ import annotations
17
18
18
19
from typing import Any , Dict , Union
19
20
20
- from hsfs import client
21
+ from hopsworks_common import client
21
22
22
23
23
24
class KafkaApi :
Original file line number Diff line number Diff line change 13
13
# See the License for the specific language governing permissions and
14
14
# limitations under the License.
15
15
#
16
+
16
17
from __future__ import annotations
17
18
18
19
import logging
21
22
22
23
import opensearchpy
23
24
import urllib3
24
- from hsfs import client
25
- from hsfs .client .exceptions import FeatureStoreException , VectorDatabaseException
26
- from hsfs .core .opensearch_api import OpenSearchApi
25
+ from hopsworks_common import client
26
+ from hopsworks_common .client .exceptions import (
27
+ FeatureStoreException ,
28
+ VectorDatabaseException ,
29
+ )
30
+ from hopsworks_common .core .opensearch_api import OpenSearchApi
27
31
from opensearchpy import OpenSearch
28
32
from opensearchpy .exceptions import (
29
33
AuthenticationException ,
Original file line number Diff line number Diff line change 13
13
# See the License for the specific language governing permissions and
14
14
# limitations under the License.
15
15
#
16
+
16
17
from __future__ import annotations
17
18
18
19
from typing import Any , Dict
19
20
20
21
from furl import furl
21
- from hsfs import client
22
- from hsfs .client .exceptions import FeatureStoreException
23
- from hsfs .core .variable_api import VariableApi
22
+ from hopsworks_common import client
23
+ from hopsworks_common .client .exceptions import FeatureStoreException
24
+ from hopsworks_common .core .variable_api import VariableApi
24
25
25
26
26
27
class OPENSEARCH_CONFIG :
Original file line number Diff line number Diff line change 13
13
# See the License for the specific language governing permissions and
14
14
# limitations under the License.
15
15
#
16
+
16
17
from __future__ import annotations
17
18
18
- from hsfs import client
19
+ from hopsworks_common import client
19
20
20
21
21
22
class ProjectApi :
Original file line number Diff line number Diff line change 13
13
# See the License for the specific language governing permissions and
14
14
# limitations under the License.
15
15
#
16
+
16
17
from __future__ import annotations
17
18
18
19
from typing import Any , Dict
19
20
20
- from hsfs import client
21
+ from hopsworks_common import client
21
22
22
23
23
24
class ServicesApi :
Original file line number Diff line number Diff line change 13
13
# See the License for the specific language governing permissions and
14
14
# limitations under the License.
15
15
#
16
+
16
17
from __future__ import annotations
17
18
18
19
import ast
21
22
from typing import TYPE_CHECKING , Literal , Union
22
23
23
24
import pytz
24
- from hsfs .core .constants import HAS_ARROW , HAS_PANDAS , HAS_POLARS
25
+ from hopsworks_common .core .constants import HAS_ARROW , HAS_PANDAS , HAS_POLARS
25
26
26
27
27
28
if TYPE_CHECKING :
Original file line number Diff line number Diff line change
1
+ #
2
+ # Copyright 2024 Hopsworks AB
3
+ #
4
+ # Licensed under the Apache License, Version 2.0 (the "License");
5
+ # you may not use this file except in compliance with the License.
6
+ # You may obtain a copy of the License at
7
+ #
8
+ # http://www.apache.org/licenses/LICENSE-2.0
9
+ #
10
+ # Unless required by applicable law or agreed to in writing, software
11
+ # distributed under the License is distributed on an "AS IS" BASIS,
12
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ # See the License for the specific language governing permissions and
14
+ # limitations under the License.
15
+ #
16
+
17
+ from hopsworks_common .code import (
18
+ Code ,
19
+ )
20
+
21
+
22
+ __all__ = [
23
+ Code ,
24
+ ]
Original file line number Diff line number Diff line change
1
+ #
2
+ # Copyright 2024 Hopsworks AB
3
+ #
4
+ # Licensed under the Apache License, Version 2.0 (the "License");
5
+ # you may not use this file except in compliance with the License.
6
+ # You may obtain a copy of the License at
7
+ #
8
+ # http://www.apache.org/licenses/LICENSE-2.0
9
+ #
10
+ # Unless required by applicable law or agreed to in writing, software
11
+ # distributed under the License is distributed on an "AS IS" BASIS,
12
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ # See the License for the specific language governing permissions and
14
+ # limitations under the License.
15
+ #
16
+
17
+ from hopsworks_common .core .code_api import (
18
+ CodeApi ,
19
+ )
20
+
21
+
22
+ __all__ = [
23
+ CodeApi ,
24
+ ]
Original file line number Diff line number Diff line change
1
+ #
2
+ # Copyright 2024 Hopsworks AB
3
+ #
4
+ # Licensed under the Apache License, Version 2.0 (the "License");
5
+ # you may not use this file except in compliance with the License.
6
+ # You may obtain a copy of the License at
7
+ #
8
+ # http://www.apache.org/licenses/LICENSE-2.0
9
+ #
10
+ # Unless required by applicable law or agreed to in writing, software
11
+ # distributed under the License is distributed on an "AS IS" BASIS,
12
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ # See the License for the specific language governing permissions and
14
+ # limitations under the License.
15
+ #
16
+
17
+ from hopsworks_common .core .code_engine import (
18
+ CodeEngine ,
19
+ RunType ,
20
+ )
21
+
22
+
23
+ __all__ = [
24
+ CodeEngine ,
25
+ RunType ,
26
+ ]
Original file line number Diff line number Diff line change
1
+ #
2
+ # Copyright 2024 Hopsworks AB
3
+ #
4
+ # Licensed under the Apache License, Version 2.0 (the "License");
5
+ # you may not use this file except in compliance with the License.
6
+ # You may obtain a copy of the License at
7
+ #
8
+ # http://www.apache.org/licenses/LICENSE-2.0
9
+ #
10
+ # Unless required by applicable law or agreed to in writing, software
11
+ # distributed under the License is distributed on an "AS IS" BASIS,
12
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ # See the License for the specific language governing permissions and
14
+ # limitations under the License.
15
+ #
16
+
17
+ from hopsworks_common .core .hosts_api import (
18
+ HostsApi ,
19
+ )
20
+
21
+
22
+ __all__ = [
23
+ HostsApi ,
24
+ ]
Original file line number Diff line number Diff line change
1
+ #
2
+ # Copyright 2024 Hopsworks AB
3
+ #
4
+ # Licensed under the Apache License, Version 2.0 (the "License");
5
+ # you may not use this file except in compliance with the License.
6
+ # You may obtain a copy of the License at
7
+ #
8
+ # http://www.apache.org/licenses/LICENSE-2.0
9
+ #
10
+ # Unless required by applicable law or agreed to in writing, software
11
+ # distributed under the License is distributed on an "AS IS" BASIS,
12
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ # See the License for the specific language governing permissions and
14
+ # limitations under the License.
15
+ #
16
+
17
+ from hopsworks_common .core .kafka_api import (
18
+ KafkaApi ,
19
+ )
20
+
21
+
22
+ __all__ = [
23
+ KafkaApi ,
24
+ ]
Original file line number Diff line number Diff line change
1
+ #
2
+ # Copyright 2024 Hopsworks AB
3
+ #
4
+ # Licensed under the Apache License, Version 2.0 (the "License");
5
+ # you may not use this file except in compliance with the License.
6
+ # You may obtain a copy of the License at
7
+ #
8
+ # http://www.apache.org/licenses/LICENSE-2.0
9
+ #
10
+ # Unless required by applicable law or agreed to in writing, software
11
+ # distributed under the License is distributed on an "AS IS" BASIS,
12
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ # See the License for the specific language governing permissions and
14
+ # limitations under the License.
15
+ #
16
+
17
+ from hopsworks_common .core .opensearch import (
18
+ OpenSearchClientSingleton ,
19
+ OpensearchRequestOption ,
20
+ )
21
+
22
+
23
+ __all__ = [
24
+ OpenSearchClientSingleton ,
25
+ OpensearchRequestOption ,
26
+ ]
Original file line number Diff line number Diff line change
1
+ #
2
+ # Copyright 2024 Hopsworks AB
3
+ #
4
+ # Licensed under the Apache License, Version 2.0 (the "License");
5
+ # you may not use this file except in compliance with the License.
6
+ # You may obtain a copy of the License at
7
+ #
8
+ # http://www.apache.org/licenses/LICENSE-2.0
9
+ #
10
+ # Unless required by applicable law or agreed to in writing, software
11
+ # distributed under the License is distributed on an "AS IS" BASIS,
12
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ # See the License for the specific language governing permissions and
14
+ # limitations under the License.
15
+ #
16
+
17
+ from hopsworks_common .core .opensearch_api import (
18
+ OPENSEARCH_CONFIG ,
19
+ OpenSearchApi ,
20
+ )
21
+
22
+
23
+ __all__ = [
24
+ OPENSEARCH_CONFIG ,
25
+ OpenSearchApi ,
26
+ ]
Original file line number Diff line number Diff line change
1
+ #
2
+ # Copyright 2024 Hopsworks AB
3
+ #
4
+ # Licensed under the Apache License, Version 2.0 (the "License");
5
+ # you may not use this file except in compliance with the License.
6
+ # You may obtain a copy of the License at
7
+ #
8
+ # http://www.apache.org/licenses/LICENSE-2.0
9
+ #
10
+ # Unless required by applicable law or agreed to in writing, software
11
+ # distributed under the License is distributed on an "AS IS" BASIS,
12
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ # See the License for the specific language governing permissions and
14
+ # limitations under the License.
15
+ #
16
+
17
+ from hopsworks_common .core .project_api import (
18
+ ProjectApi ,
19
+ )
20
+
21
+
22
+ __all__ = [
23
+ ProjectApi ,
24
+ ]
You can’t perform that action at this time.
0 commit comments