Prefect Community

<@ULVA73B9P> How do i upgrade from prefect v2 to v3 without losing any data for variables, blocks an...

a

Abhishek Singh

8 months ago

@Marvin How do i upgrade from prefect v2 to v3 without losing any data for variables, blocks and deployments

a

m

2
7
100

<@ULVA73B9P> i'm using this code from the docs ``` async def cancel_flow_runs(flow_runs): asyn...

a

Arthur

9 months ago

@Marvin i'm using this code from the docs

async def cancel_flow_runs(flow_runs):
    async with get_client() as client:
        for idx, flow_run in enumerate(flow_runs):
            print(f"[{idx + 1}] Cancelling flow run '{flow_run.name}' with ID '{flow_run.id}'")
            state_updates = {}
            state_updates.setdefault("name", "Cancelled")
            state_updates.setdefault("type", StateType.CANCELLED)
            state = flow_run.state.copy(update=state_updates)
            await client.set_flow_run_state(flow_run.id, state, force=True)

but it fails with

TypeError: 'MockValSer' object cannot be converted to 'SchemaSerializer'

. why?

a

m

2
25
100

<@U02EFFCT5JP> Would like to know in prefect2 `signals` is changed to which supported format?I nee...

s

sjammula

over 2 years ago

@prefect Would like to know in prefect2

signals

is changed to which supported format?I need to raise exceptions failed states.Please do provide the needful info

✅ 1

s

r

2
8
100

Fun with dataframes and map. So I have a map function that loads a dataframe in one task and then us...

d

David Haynes

over 3 years ago

Fun with dataframes and map. So I have a map function that loads a dataframe in one task and then uses that dataframe in the next task. When I look at the return type on the first task, it is pandas.core.frame.DataFrame. When I look at the type of the dataframe value in the second task, it is class 'list'. I have the type hint set to pandas.DataFrame in the second task. Does anyone have any idea why the DataFrame is becoming a list?

d

k

2
8
100

I’m running orion `2.0b2` and starting the server (on an EC2 machine) with an IP on a different port...

r

Ricardo Gaspar

over 3 years ago

I’m running orion

2.0b2

and starting the server (on an EC2 machine) with an IP on a different port. (self-hosted). I’m able to connect to it via browser (I’ve set all the security groups and routes to allow me to connect to it on a browser). However it seems that internally Prefect Orion is still interacting with the default host and port. So the UI doesn’t render all the info (see screenshot in the thread) Is there something extra I need to change?

r

k

+2

4
7
100

<@ULVA73B9P> I am using coolify on a GCP VM, I used the template of prefect which was not working wh...

f

Ferdinand Harmel

11 months ago

@Marvin I am using coolify on a GCP VM, I used the template of prefect which was not working when launching with the error :

Can't connect to Server API at <http://127.0.0.1:4200/api>. Check that it's accessible from your machine.

I did some research, and from what I understand, it comes from network issue. But I can't see which one... Here's my docker-compose:

services:
  prefect:
    image: 'prefecthq/prefect:3-latest'
    depends_on:
      postgresql:
        condition: service_healthy
    environment:
      - SERVICE_FQDN_PREFECT_4200
      - 'PREFECT_API_DATABASE_CONNECTION_URL=postgresql+asyncpg://${SERVICE_USER_POSTGRES}:${SERVICE_PASSWORD_POSTGRES}@postgresql:5432/${POSTGRES_DB:-prefect}'
      - 'PREFECT_API_KEY=${SERVICE_PASSWORD_APIKEY}'
      - 'PREFECT_EXPERIMENTAL_WARN=${PREFECT_EXPERIMENTAL_WARN:-false}'
      - 'PREFECT_EXPERIMENTAL_ENABLE_SCHEDULE_CONCURRENCY=${PREFECT_EXPERIMENTAL_ENABLE_SCHEDULE_CONCURRENCY:-false}'
      - 'PREFECT_RUNNER_SERVER_ENABLE=${PREFECT_RUNNER_SERVER_ENABLE:-false}'
      - 'PREFECT_DEFAULT_WORK_POOL_NAME=${DEFAULT_POOL_NAME:-default}'
      - 'PREFECT_API_URL=<http://0.0.0.0:4200/api>'
      - 'PREFECT_SERVER_API_HOST=127.0.0.1'
      #- 'PREFECT_UI_API_URL=<http://localhost:4200/api>'
      #- 'PREFECT_UI_API_URL=<http://127.0.0.1:4200/api>'
    command:
      - prefect
      - server
      - start
      - '--host'
      - 0.0.0.0
      - '--port'
      - '4200'
    healthcheck:
      test:
        - CMD
        - python
        - '-c'
        - "import requests as r;r.get('<http://127.0.0.1:4200/api/health').raise_for_status(>)"
      interval: 5s
      timeout: 5s
      retries: 3
  postgresql:
    image: 'postgres:16-alpine'
   ...

Also I tried to relate with this issue, but couldn't see the bottom of it https://linen.prefect.io/t/9562601/hi-guys-hope-someone-can-help-me-with-my-current-problem-i-h Under the hood coolify use docker-compose, but it shouldn't interfer since it's in the local network of dockers...

f

m