We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0c2ea86 commit 3a8eb92Copy full SHA for 3a8eb92
2 files changed
src/fastapi_cloudflow/core/arg.py
@@ -47,8 +47,5 @@ def expr(expression: str) -> ArgExpr:
47
48
@staticmethod
49
def base64(value: str | ArgExpr) -> ArgExpr:
50
- if isinstance(value, ArgExpr):
51
- inner = value.expr
52
- else:
53
- inner = json.dumps(value)
+ inner = value.expr if isinstance(value, ArgExpr) else json.dumps(value)
54
return ArgExpr(f"base64.encode({inner})")
src/fastapi_cloudflow/core/connectors.py
@@ -88,7 +88,7 @@ class PubSubPublishResult(BaseModel):
88
message_ids: list[str]
89
90
91
-def pubsub_publish_step(
+def pubsub_publish_step[InT: BaseModel, OutT: BaseModel](
92
*,
93
name: str,
94
topic: str,
0 commit comments