• seunggs

    seunggs

    2 months ago
    Is there a way to skip the y/n confirmation with flytectl?
    This action will overwrite an existing config file at [/.flyte/config.yaml]. Do you want to continue? [y/n]:
    seunggs
    y
    2 replies
    Copy to Clipboard
  • seunggs

    seunggs

    2 months ago
    While running
    flytectl config init --host=<http://example.com|example.com>
  • Bryan Yeung

    Bryan Yeung

    2 months ago
    After setting up a cluster, with metallb + contour ingress (default install with helm flyte sandbox instructions), deploying a sample with command line receives a grpc error:
    pyflyte run --remote example.py wf --n 500 --mean 42 --sigma 2
    {"asctime": "2022-07-20 21:46:45,700", "name": "flytekit.cli", "levelname": "ERROR", "message": "Non-auth RPC error <_InactiveRpcError of RPC that terminated with:\n\tstatus = StatusCode.UNAVAILABLE\n\tdetails = \"failed to connect to all addresses\"\n\tdebug_error_string = \"{\"created\":\"@1658378805.700485000\",\"description\":\"Failed to pick subchannel\",\"file\":\"src/core/ext/filters/client_channel/client_channel.cc\",\"file_line\":3261,\"referenced_errors\":[{\"created\":\"@1658378805.700485000\",\"description\":\"failed to connect to all addresses\",\"file\":\"src/core/lib/transport/error_utils.cc\",\"file_line\":167,\"grpc_status\":14}]}\"\n>, sleeping 200ms and retrying"}
    {"asctime": "2022-07-20 21:46:45,906", "name": "flytekit.cli", "levelname": "ERROR", "message": "Non-auth RPC error <_InactiveRpcError of RPC that terminated with:\n\tstatus = StatusCode.UNAVAILABLE\n\tdetails = \"failed to connect to all addresses\"\n\tdebug_error_string = \"{\"created\":\"@1658378805.905927000\",\"description\":\"Failed to pick subchannel\",\"file\":\"src/core/ext/filters/client_channel/client_channel.cc\",\"file_line\":3261,\"referenced_errors\":[{\"created\":\"@1658378805.905926000\",\"description\":\"failed to connect to all addresses\",\"file\":\"src/core/lib/transport/error_utils.cc\",\"file_line\":167,\"grpc_status\":14}]}\"\n>, sleeping 400ms and retrying"}
    Traceback (most recent call last):
      File "/Users/btyeung/.virtualenvs/flyte/bin/pyflyte", line 8, in <module>
        sys.exit(main())
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/click/core.py", line 1130, in __call__
        return self.main(*args, **kwargs)
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/click/core.py", line 1055, in main
        rv = self.invoke(ctx)
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/click/core.py", line 1657, in invoke
        return _process_result(sub_ctx.command.invoke(sub_ctx))
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/click/core.py", line 1657, in invoke
        return _process_result(sub_ctx.command.invoke(sub_ctx))
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/click/core.py", line 1657, in invoke
        return _process_result(sub_ctx.command.invoke(sub_ctx))
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/click/core.py", line 1404, in invoke
        return ctx.invoke(self.callback, **ctx.params)
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/click/core.py", line 760, in invoke
        return __callback(*args, **kwargs)
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/flytekit/clis/sdk_in_container/run.py", line 516, in _run
        remote_entity = remote.register_script(
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/flytekit/remote/remote.py", line 596, in register_script
        upload_location, md5_bytes = fast_register_single_script(
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/flytekit/tools/script_mode.py", line 116, in fast_register_single_script
        upload_location = create_upload_location_fn(content_md5=md5)
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/flytekit/clients/friendly.py", line 998, in get_upload_signed_url
        return super(SynchronousFlyteClient, self).create_upload_location(
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/flytekit/clients/raw.py", line 42, in handler
        return fn(*args, **kwargs)
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/flytekit/clients/raw.py", line 859, in create_upload_location
        return self._dataproxy_stub.CreateUploadLocation(create_upload_location_request, metadata=self._metadata)
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
        return _end_unary_response_blocking(state, call, False, None)
      File "/Users/btyeung/.virtualenvs/flyte/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
        raise _InactiveRpcError(state)
    grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
            status = StatusCode.UNAVAILABLE
            details = "failed to connect to all addresses"
            debug_error_string = "{"created":"@1658378806.310949000","description":"Failed to pick subchannel","file":"src/core/ext/filters/client_channel/client_channel.cc","file_line":3261,"referenced_errors":[{"created":"@1658378806.310944000","description":"failed to connect to all addresses","file":"src/core/lib/transport/error_utils.cc","file_line":167,"grpc_status":14}]}"
    >
  • Bryan Yeung

    Bryan Yeung

    2 months ago
    The loadbalancer (metallb) successfully provided an IP address, and console is available through that address. Here is flyte config.yaml
    admin:
      # For GRPC endpoints you might want to use dns:///flyte.myexample.com
      endpoint: dns:///192.168.111.220
      insecure: true
    logger:
      show-source: true
      level: 0
    Here is a screenshot of the console:
    Bryan Yeung
    y
    +1
    18 replies
    Copy to Clipboard
  • Bryan Yeung

    Bryan Yeung

    2 months ago
  • Bernhard Stadlbauer

    Bernhard Stadlbauer

    2 months ago
    Hi! I've been looking into the docs for Notifications (and also checked the corresponding admin code). From what I could gather, GCP support for creating events (in Pub/Sub) already exists, but there is currently no way of sending email notifications with GCP (i.e. no
    emailer
    for GCP). Just wanted to confirm whether that is correct or if I am missing something?
    Bernhard Stadlbauer
    Ketan (kumare3)
    +4
    12 replies
    Copy to Clipboard
  • Sandra Youssef

    Sandra Youssef

    2 months ago
    Hi Flyers,Flyte will be featured tomorrow 7/22 on Kelsey Hightower's Twitter Space: Machine Learning in Production Join @Ketan (kumare3) and @Eduardo Apolinario (eapolinario), plus guest speakers @Fabio Grätz, @Evan Sadler, @Arno Hollosi, Jordan Ganoff and Gautam Kedia for insights into unified machine learning and data orchestration. 7/22 at 10am PTEvent link (also QR code in the flyer)
  • Jordan Ganoff

    Jordan Ganoff

    2 months ago
    👋 Hi everyone!
  • j

    Josh Kilts

    2 months ago
    👋 Hello everyone. I'm exploring flyte as a potential tool for my team and have a question I can't seem find an answer to: Is there any mechanism for configuring the python runtime environment for a task? Other tools I've explored have allowed me to pass in a list of packages (or a requirements.txt) and I'm looking for something similar.
    j
    Yee
    +1
    13 replies
    Copy to Clipboard
  • g

    George Snelling

    2 months ago
    Hi everybody, I have a simple question that is very deployment- and workflow-specific for those of you who use Flyte in production: Do you know the mean and the median time for task executions throughout your organization? And if so, can you share? Either publicly if that makes sense for your organization (in this thread please), or privately via DM. If you don't know, that would be useful to understand too. Thanks!