Remove invalid testing

Author: tconley1428

tests/worker/test_workflow.py

@@ -8369,88 +8369,3 @@ async def test_previous_run_failure(client: Client):
         )
         result = await handle.result()
         assert result == "Done"
-
-class EncryptionCodec(PayloadCodec):
-    def __init__(self, key_id: str = "test-key-id", key: bytes = b"test-key-test-key-test-key-test!") -> None:
-        super().__init__()
-        self.key_id = key_id
-
-    async def encode(self, payloads: Iterable[Payload]) -> List[Payload]:
-        # We blindly encode all payloads with the key and set the metadata
-        # saying which key we used
-        return [
-            Payload(
-                metadata={
-                    "encoding": b"binary/encrypted",
-                    "encryption-key-id": self.key_id.encode(),
-                },
-                data=self.encrypt(p.SerializeToString()),
-            )
-            for p in payloads
-        ]
-
-    async def decode(self, payloads: Iterable[Payload]) -> List[Payload]:
-        ret: List[Payload] = []
-        for p in payloads:
-            # Ignore ones w/out our expected encoding
-            if p.metadata.get("encoding", b"").decode() != "binary/encrypted":
-                ret.append(p)
-                continue
-            # Confirm our key ID is the same
-            key_id = p.metadata.get("encryption-key-id", b"").decode()
-            if key_id != self.key_id:
-                raise ValueError(f"Unrecognized key ID {key_id}. Current key ID is {self.key_id}.")
-            # Decrypt and append
-            ret.append(Payload.FromString(self.decrypt(p.data)))
-        return ret
-
-    def encrypt(self, data: bytes) -> bytes:
-        nonce = os.urandom(12)
-        return data
-
-    def decrypt(self, data: bytes) -> bytes:
-        return data
-
-
-@workflow.defn(name="Workflow")
-class GreetingWorkflow:
-    @workflow.run
-    async def run(self, name: str) -> str:
-        print(
-            await workflow.execute_child_workflow(
-                workflow=ChildWorkflow.run,
-                arg=name,
-                id=f"child-{name}",
-                search_attributes=workflow.info().typed_search_attributes,
-            )
-        )
-        return f"Hello, {name}"
-
-
-@workflow.defn(name="ChildWorkflow")
-class ChildWorkflow:
-    @workflow.run
-    async def run(self, name: str) -> str:
-        return f"Hello from child, {name}"
-
-async def test_search_attribute_codec(client: Client):
-
-    config = client.config()
-    config["data_converter"] = dataclasses.replace(temporalio.converter.default(), payload_codec=EncryptionCodec())
-    client = Client(**config)
-    # Run a worker for the workflow
-    async with Worker(
-        client,
-        task_queue="encryption-task-queue",
-        workflows=[GreetingWorkflow, ChildWorkflow],
-    ):
-        # Run workflow
-        result = await client.execute_workflow(
-            GreetingWorkflow.run,
-            "Temporal",
-            id=f"encryption-workflow-id",
-            task_queue="encryption-task-queue",
-            search_attributes=TypedSearchAttributes(
-                [SearchAttributePair(SearchAttributeKey.for_keyword("show_name"), "test_show")]
-            ),
-        )