We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ad01ca3 commit 7e710bfCopy full SHA for 7e710bf
llmstack/data/serializers.py
@@ -26,18 +26,21 @@ def get_type(self, obj):
26
"name": "Custom",
27
}
28
29
+ def _get_config(self, obj):
30
+ return obj.config or {}
31
+
32
def get_pipeline(self, obj):
- return obj.config.get("pipeline", None)
33
+ return self._get_config().get("pipeline", None)
34
35
def get_refresh_interval(self, obj):
- return obj.config.get("refresh_interval", None)
36
+ return self._get_config().get("refresh_interval", None)
37
38
def get_has_source(self, obj):
- return obj.config.get("pipeline", {}).get("source", {}).get("slug", None) is not None
39
+ return self._get_config().get("pipeline", {}).get("source", {}).get("slug", None) is not None
40
41
def get_is_destination_only(self, obj):
42
return (
- obj.config.get("pipeline", {}).get("destination", {}).get("slug", None) is not None
43
+ self._get_config().get("pipeline", {}).get("destination", {}).get("slug", None) is not None
44
and self.get_has_source(obj) is False
45
)
46
0 commit comments