• a

    Alex Cano

    2 years ago
    Flows can’t have a schedule in server (same in cloud?) if they have required parameters, right?
    a
    Zachary Hughes
    6 replies
    Copy to Clipboard
  • a

    Azuma

    2 years ago
    Hello everyone! Please tell me if the server starts as follows:1) prefect backend server 2) prefect server start Where does config.toml come from if I need to change the endpoint in it? 1) ~ / .prefect / config.toml 2) prefect / src / prefect / config.toml 3) prefect / server / src / prefect_server / config.toml? I fluently tried all 3 options, but it did not bring success = (
    a
    a
    +1
    6 replies
    Copy to Clipboard
  • b

    Barry Roszak

    2 years ago
    Is it possible to run mapped tasks in parallel using docker agent?
    b
    Chris White
    8 replies
    Copy to Clipboard
  • q

    Questionnaire

    2 years ago
    Hey folks, I'm a begginer here.... Can someone share me the step by step process for third party authentication like AWS. I read docs but it's not clear to me.
    q
    Jim Crist-Harif
    49 replies
    Copy to Clipboard
  • z

    Zach

    2 years ago
    I am trying to register one of my flows and I am getting this error that I don't understand:
    Traceback (most recent call last):
      File "/opt/prefect/healthcheck.py", line 135, in <module>
        flows = cloudpickle_deserialization_check(flow_file_path)
      File "/opt/prefect/healthcheck.py", line 40, in cloudpickle_deserialization_check
        flows.append(cloudpickle.load(f))
    ModuleNotFoundError: No module named 'prefect.engine.results.prefect_result'
  • z

    Zach

    2 years ago
    That
    prefect_result
    module does exist in the prefect package code that I have installed. So why is it saying it doesn't? I can't see how my code would cause this to break, since all the errors seem to be coming from the prefect package code
    z
    1 replies
    Copy to Clipboard
  • z

    Zach

    2 years ago
    I thought the v0.11.0 was supposed to be non-breaking but it seems to have broken several things for us.
  • m

    Marwan Sarieddine

    2 years ago
    Hi everyone - new to prefect, I got a the server running on prefect cloud, along with a kuberenetes agent that is polling from the server - I registered a flow that shows up on the server and I am trying to run it but I am getting an error. I am following the [Docker Sidecar on Kubernetes deployment recipe](https://docs.prefect.io/orchestration/recipes/k8s_docker_sidecar.html) I did not do any code changes and used the flow script as is - I am running prefect version
    0.10.7
    and I am getting the below error in the logs
    19 May 2020,01:03:00 	agent	INFO	Submitted for execution: Job prefect-job-d7e49926
    19 May 2020,01:03:26 	prefect.CloudFlowRunner	INFO	Beginning Flow run for 'Run a Prefect Flow in Docker'
    19 May 2020,01:03:27 	prefect.CloudFlowRunner	INFO	Starting flow run.
    19 May 2020,01:03:27 	prefect.CloudTaskRunner	INFO	Task 'PullImage': Starting task run...
    19 May 2020,01:03:27 	prefect.CloudTaskRunner	ERROR	Unexpected error: DockerException("Error while fetching server API version: HTTPConnectionPool(host='localhost', port=2375): Max retries exceeded with url: /version (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f8768ed7c10>: Failed to establish a new connection: [Errno 111] Connection refused'))")
    Traceback (most recent call last):
      File "/usr/local/lib/python3.7/site-packages/urllib3/connection.py", line 160, in _new_conn
        (self._dns_host, self.port), self.timeout, **extra_kw
      File "/usr/local/lib/python3.7/site-packages/urllib3/util/connection.py", line 84, in create_connection
        raise err
      File "/usr/local/lib/python3.7/site-packages/urllib3/util/connection.py", line 74, in create_connection
        sock.connect(sa)
    ConnectionRefusedError: [Errno 111] Connection refused
    It seems that
    localhost:2375
    (docker daemon address is not reachable for some reason) - anyone faced this issue before ?
    m
    Zachary Hughes
    +1
    6 replies
    Copy to Clipboard
  • s

    Sanjay Patel

    2 years ago
    Hello! is there a way to use **kwargs with the prefect map function as per the below?
    changes = generator_task.map(
                    sim, 
                    unmapped(x), 
                    unmapped(y),
                    unmapped(z),
                    **kwargs #need this unmapped
                )
    s
    Jim Crist-Harif
    6 replies
    Copy to Clipboard
  • h

    hakki cankaya

    2 years ago
    Is there any url or example/tutorial that explains how resilient prefect scheduler is?
    h
    1 replies
    Copy to Clipboard