File tree 1 file changed +2
-3
lines changed
airbyte-integrations/connectors/source-declarative-manifest/source_declarative_manifest
1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change 4
4
from __future__ import annotations
5
5
6
6
import json
7
- import os
8
7
import pkgutil
9
8
import sys
10
9
from pathlib import Path
11
10
from typing import List
12
11
13
12
from airbyte_cdk .connector import BaseConnector
14
13
from airbyte_cdk .entrypoint import AirbyteEntrypoint , launch
15
- from airbyte_cdk .models import AirbyteMessage , ConnectorSpecification , Type
14
+ from airbyte_cdk .models import AirbyteMessage , ConnectorSpecificationSerializer , Type
16
15
from airbyte_cdk .sources .declarative .manifest_declarative_source import ManifestDeclarativeSource
17
16
from airbyte_cdk .sources .declarative .yaml_declarative_source import YamlDeclarativeSource
18
17
@@ -64,7 +63,7 @@ def handle_remote_manifest_command(args: List[str]) -> None:
64
63
if args [0 ] == "spec" :
65
64
json_spec = pkgutil .get_data ("source_declarative_manifest" , "spec.json" )
66
65
spec_obj = json .loads (json_spec )
67
- spec = ConnectorSpecification . parse_obj (spec_obj )
66
+ spec = ConnectorSpecificationSerializer . load (spec_obj )
68
67
69
68
message = AirbyteMessage (type = Type .SPEC , spec = spec )
70
69
print (AirbyteEntrypoint .airbyte_message_to_string (message ))
You can’t perform that action at this time.
0 commit comments