async def METHOD_NAME(self):
    df = self._create_dataflow_with_op(db_query_create_table)
    test_inputs = {
        "create": {"table_name": self.table_name, "cols": self.cols}
    }
    async with MemoryOrchestrator.withconfig({}) as orchestrator:
        async with orchestrator(df) as octx:
            async for _ctx, results in octx.run(
                {
                    test_ctx: [
                        Input(
                            value=val,
                            definition=db_query_create_table.op.inputs[
                                key
                            ],
                        )
                        for key, val in test_val.items()
                    ]
                    for test_ctx, test_val in test_inputs.items()
                }
            ):
                pass
        async with self.sdb as db:
            async with db() as db_ctx:
                query = (
                    "SELECT count(name) FROM sqlite_master "
                    + f" WHERE type='table' and name='{self.table_name}' "
                )
                db_ctx.parent.cursor.execute(query)
                results = db_ctx.parent.cursor.fetchone()
                self.assertEqual(results["count(name)"], 1)