simplecast: fix schema
Signed-off-by: Alexis Pentori <alexis@status.im>
This commit is contained in:
parent
204812e8f8
commit
e34407cffb
|
@ -14,7 +14,7 @@ data:
|
||||||
connectorSubtype: api
|
connectorSubtype: api
|
||||||
connectorType: source
|
connectorType: source
|
||||||
definitionId: 464a7cea-0317-485e-9a9c-bcd06155bfff
|
definitionId: 464a7cea-0317-485e-9a9c-bcd06155bfff
|
||||||
dockerImageTag: 1.1.0
|
dockerImageTag: 1.1.1
|
||||||
dockerRepository: harbor.status.im/status-im/airbyte/source-simplecast-fetcher
|
dockerRepository: harbor.status.im/status-im/airbyte/source-simplecast-fetcher
|
||||||
githubIssueLabel: source-simplecast-fecther
|
githubIssueLabel: source-simplecast-fecther
|
||||||
icon: simplecast-fecther.svg
|
icon: simplecast-fecther.svg
|
||||||
|
|
|
@ -71,3 +71,4 @@
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
|
@ -47,7 +47,7 @@ class SimplecastFectherStream(HttpStream):
|
||||||
|
|
||||||
class Podcast(SimplecastFectherStream):
|
class Podcast(SimplecastFectherStream):
|
||||||
|
|
||||||
primary_key = "podcast_id"
|
primary_key = "id"
|
||||||
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
|
@ -75,7 +75,7 @@ class Podcast(SimplecastFectherStream):
|
||||||
yield podcast
|
yield podcast
|
||||||
|
|
||||||
class Episode(HttpSubStream, SimplecastFectherStream):
|
class Episode(HttpSubStream, SimplecastFectherStream):
|
||||||
primary_key="episode_id"
|
primary_key="id"
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def use_cache(self) -> bool:
|
def use_cache(self) -> bool:
|
||||||
|
@ -141,7 +141,7 @@ class AnalyticSubStream(HttpSubStream, SimplecastFectherStream, ABC):
|
||||||
yield analytic
|
yield analytic
|
||||||
|
|
||||||
class AnalyticLocation(AnalyticSubStream):
|
class AnalyticLocation(AnalyticSubStream):
|
||||||
primary_key="analytic_location_id"
|
primary_key=None
|
||||||
|
|
||||||
def __init__(self, **kwargs):
|
def __init__(self, **kwargs):
|
||||||
super().__init__(endpoint="location", keys_dict=LOCATION_KEYS, collection_name="countries", **kwargs)
|
super().__init__(endpoint="location", keys_dict=LOCATION_KEYS, collection_name="countries", **kwargs)
|
||||||
|
|
Loading…
Reference in New Issue