Transforms a directed acyclic graph (DAG) into code.
Parameters:
-
dag_nodes
(Optional[DagNodes], default:
None
)
–
A list of the nodes in the DAG.
-
dag_edges
(Optional[DagEdges], default:
None
)
–
A list of the edges in the DAG.
-
language
(Optional[Language], default:
None
)
–
The programming language of the resulting code from the DAG.
Raises:
Source code in docs_src/capo_glue/_services/glue.py
| def create_script(
self,
*,
config_overrides: Optional[GlueClientConfig] = None,
dag_nodes: Optional["capo_glue.types.dag_nodes.DagNodes"] = None,
dag_edges: Optional["capo_glue.types.dag_edges.DagEdges"] = None,
language: Optional["capo_glue.types.language.Language"] = None,
) -> "capo_glue.types.create_script_response.CreateScriptResponse":
"""<p>Transforms a directed acyclic graph (DAG) into code.</p>
Args:
dag_nodes: <p>A list of the nodes in the DAG.</p>
dag_edges: <p>A list of the edges in the DAG.</p>
language: <p>The programming language of the resulting code from the DAG.</p>
Raises:
capo_glue.errors.internal_service_exception.InternalServiceException: <p>An internal service error occurred.</p>
capo_glue.errors.invalid_input_exception.InvalidInputException: <p>The input provided was not valid.</p>
capo_glue.errors.operation_timeout_exception.OperationTimeoutException: <p>The operation timed out.</p>
capo_glue.errors.UnknownServiceError: The service returned an error code this client does not model.
"""
def _handler(
req: "OperationRequest[capo_glue.types.create_script_request.CreateScriptRequest]",
) -> OperationResponse[
"capo_glue.types.create_script_response.CreateScriptResponse"
]:
import capo_glue._operations.aws_glue.create_script
output, http_response = (
capo_glue._operations.aws_glue.create_script.create_script(
req.options, req.input
)
)
return OperationResponse(output=output, response=http_response)
interceptors_, options_ = self.operation_options(
config_overrides, OperationLogging("CreateScript")
)
input_: capo_glue.types.create_script_request.CreateScriptRequest = {}
if dag_nodes is not None:
input_["dag_nodes"] = dag_nodes
if dag_edges is not None:
input_["dag_edges"] = dag_edges
if language is not None:
input_["language"] = language
response = execute_pipeline(
OperationRequest(input=input_, options=options_),
handler=_handler,
interceptors=list(interceptors_),
)
response.response.close()
return response.output
|