jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-25 02:09:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

#1840 Issue: Update configured_catalog for Sendgrid for testing all streams (#1913)

Browse Source 
Co-authored-by: Sherif Nada <snadalive@gmail.com>
This commit is contained in:
Yevhenii
2021-02-02 20:13:33 +02:00
committed by GitHub
parent 3abf317dda
commit 3316d38671
5 changed files with 36 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
airbyte-integrations/connectors/source-sendgrid/integration_tests/configured_catalog.json
View File

@@ -1,5 +1,35 @@
{
"streams": [
{
"stream": {
"name": "campaigns",
"json_schema": {
"$schema": "http://json-schema.org/draft-07/schema#",
"type": "object",
"properties": {
"id": {
"type": "string"
},
"name": {
"type": "string"
},
"created_at": {
"type": "string"
},
"status": {
"type": "string"
},
"updated_at": {
"type": "string"
},
"is_abtest": {
"type": "boolean"
}
}
},
"supported_sync_modes": ["full_refresh"]
}
},
{
"stream": {
"name": "lists",

25
airbyte-integrations/connectors/source-sendgrid/integration_tests/standard_source_test.py
View File

@@ -22,27 +22,8 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
SOFTWARE.
"""
import json
import pkgutil
from airbyte_protocol import ConfiguredAirbyteCatalog, ConnectorSpecification
from base_python_test import StandardSourceTestIface
from base_python_test import DefaultStandardSourceTest
class SourceSendgridStandardTest(StandardSourceTestIface):
def get_spec(self) -> ConnectorSpecification:
raw_spec = pkgutil.get_data(self.__class__.__module__.split(".")[0], "spec.json")
return ConnectorSpecification.parse_obj(json.loads(raw_spec))
def get_config(self) -> object:
return json.loads(pkgutil.get_data(self.__class__.__module__.split(".")[0], "config.json"))
def get_catalog(self) -> ConfiguredAirbyteCatalog:
raw_catalog = pkgutil.get_data(self.__class__.__module__.split(".")[0], "configured_catalog.json")
return ConfiguredAirbyteCatalog.parse_obj(json.loads(raw_catalog))
def setup(self) -> None:
pass
def teardown(self) -> None:
pass
class SourceSendgridStandardTest(DefaultStandardSourceTest):
pass