create_link_pipeline

create_link_pipeline은 Link SDK에서의 파이프라인을 생성하는 클래스인 LinkPipeline을 생성하는 메소드입니다.

파이프라인 생성

create_link_pipeline(
    identifier: Optional[str] = None,
    components: Optional[List[MRXLinkComponentModel]] = None,
    edges: Optional[List[MRXLinkDagEdgeModel]] = None,
    parameters: Optional[List[MRXLinkPipelineParameterModel]] = None,
) -> LinkPipeline

• Parameters
  • identifier(str): 해당 파이프라인의 ID
  • components(list): 해당 파이프라인의 components (MRXLinkComponentModel)
  • edges(list): 해당 파이프라인의 edges (MRXLinkDagEdgeModel)
  • parameters(list): 해당 파이프라인의 parameters (MRXLinkPipelineParameterModel)
• Returns
  • LinkPipeline(identifier, components, edges, parameters)
• Troubleshooting
  • RuntimeError: User configuration is required. For user configuration, try 'mrx-link login' in the command line interface.
    • 유저 정보가 필요한 경우에 (로그인이 필요한 경우에) 발생합니다.
  • ConnectionError: Check your internet connection and try again.
    • 인터넷 요청 에러 또는 타임아웃 상황에서 발생합니다.
  • ValueError: Invalid email or product key. Please check your email and product key again.
    • 이메일 또는 product key 값이 잘못된 경우 발생합니다.
  • ConnectionError: An unknown error occurred. If the problem continues, visit https://makinarocks-link.readme.io/discuss for discussion, or https://link.makinarocks.ai/technical_support/ for technical support.
    • 인터넷 연결 중 원인을 알 수 없는 문제 상황에서 발생합니다.
  • ValueError: Pipeline parameter names should not be duplicated: ['name']
    • 파이프라인 파라미터 이름이 중복될 때 발생합니다.

Example

Python

from mrx_link.sdk.utils import *

# 코드 셀
code1 = """
x = 1
"""
code2 = """
print(f"{x=}, {y=}")
"""

if __name__ == "__main__":
    # 컴포넌트 생성
    component1 = create_link_component(identifier="111-1", name="test", code=code1)
    component2 = create_link_component(identifier="111-2", name="test2", code=code2)
    components = [component1, component2]

    # 컴포넌트 연결 관계 정의
    edge1 = create_link_edge(parent_id="111-1", child_id="111-2")
    edges = [edge1]

    # 파이프라인 파라미터 생성
    parameter1 = create_link_parameter(name="x", value="123")
    parameter2 = create_link_parameter(name="y", value="baregasdv")
    parameters = [parameter1, parameter2]

    # 파이프라인 생성
    pipeline = create_link_pipeline(components=components, parameters=parameters, edges=edges)

    # 파이프라인 출력
    pipeline.print()

Output

##### PIPELINE #####
ID     Name    Status    Parent IDs
-----  ------  --------  ------------
111-1  test    Ready     []
111-2  test2   Ready     ['111-1']

##### PARAMETERS #####
Name    Type    Value
------  ------  -----------
x       str     "123"
y       str     "baregasdv"