Babis Kiosidis
11/23/2022, 2:09 PMKetan (kumare3)
Babis Kiosidis
11/23/2022, 3:25 PMasync def test_generate_uri_persisted(self) -> None:
partition = two_weeks_ago().strftime("%Y-%m-%d")
execution = SdkRemoteHadesTaskReference.generate_uri(
endpoint=TestHadesTasks.ENDPOINT_DAILY,
partition=partition,
uri_prefix="<file://test>",
overwrite=False,
)
assert execution.error is not None
assert execution.error.code == "USER:Persisted"
assert execution.closure.phase == TestHadesTasks.FAILED
async def test_generate_uri_overwrite(self) -> None:
partition = two_weeks_ago().strftime("%Y-%m-%d")
execution = SdkRemoteHadesTaskReference.generate_uri(
endpoint=TestHadesTasks.ENDPOINT_DAILY,
partition=partition,
uri_prefix="<file://test>",
overwrite=True,
)
assert execution.error is None
assert execution.closure.phase == TestHadesTasks.SUCCEEDED
assert execution.outputs.get("uri").startswith(
"<file://test/di.golden.path.EndContentFactXT2/{}/>".format(partition)
)
Ketan (kumare3)
Babis Kiosidis
11/23/2022, 3:27 PMKetan (kumare3)
Babis Kiosidis
11/23/2022, 3:58 PM