@Marvin how do I manually retry a task?

Hello guys, I need help with the prefect-server ingress. The values.yaml file has no way of adding the service port number for the ingress, even when I uncomment the servicePort, the helm install complains about it...

ingress:
  # -- enable ingress record generation for server
  enabled: true

  # -- port for the ingress' main path
  #servicePort: 4200

  ## This is supported in Kubernetes 1.18+ and required if you have more than one IngressClass marked as the default for your cluster .
  ## ref: <https://kubernetes.io/blog/2020/04/02/improvements-to-the-ingress-api-in-kubernetes-1.18/>
  # -- IngressClass that will be used to implement the Ingress (Kubernetes 1.18+)
  className: ""
  host:
    # -- default host for the ingress record
    hostname: ${HOST_NAME}
    # -- default path for the ingress record
    path: /

    # -- ingress path type
    pathType: Prefix

Hi, When I run prefect deployment build command, it is not considering the virtual env that is activated. It shows no module found for few modules, though those are installed in the same virtual env.

Script at 'gpt_review.py' encountered an exception: ModuleNotFoundError("No module named 'tqdm'")

See the below command, I ran prefect deployment command, it throws the error, when I import the module in python shell, it is imported. How to create prefect deployment with virtual env?

(myenv) navaneethan_ramasamy_turing_com@character-ai:/var/opt/repo/delivery-workflow$ prefect deployment build gpt_review.py:gpt_review --name=gpt_review
Script at 'gpt_review.py' encountered an exception: ModuleNotFoundError("No module named 'tqdm'")
(myenv) navaneethan_ramasamy_turing_com@character-ai:/var/opt/repo/delivery-workflow$ ipython
Python 3.10.13 (main, Sep 11 2023, 13:44:35) [GCC 11.2.0]
Type 'copyright', 'credits' or 'license' for more information
IPython 8.22.2 -- An enhanced Interactive Python. Type '?' for help.

In [1]: import tqdm

In [2]:                                                                                                                                                                                                                    
Do you really want to exit ([y]/n)? 
(myenv) navaneethan_ramasamy_turing_com@character-ai:/var/opt/repo/delivery-workflow$

@Marvin how do I create flow-runs to backfill a schedule?

How does one get the current flow run url programmatically?

Hi. I'm having an issue using a

LocalRun

flow's

working_dir

parameter. Whenever I specify the following:

flow.run_config = LocalRun(_working_dir_='C:/scripts/GetADUsers', _labels_=["SVRBIPTH01"])

Whenever I register the flow (I'm using Prefect 1.2.0 on MacOS python 3.10) I get the following working_dir on the UI of Prefect Cloud:

/Users/carloscueto/Documents/Python_Scripts/Prefect-Flows/PowerShell/GetADUsers/C:/scripts/GetADUsers

It seems to be adding the path from where I register the script from (on the local machine) to the working_dir string I specified on the run_config. Has anybody encountered this before? Everything works fine when I register the flow from a Windows computer.

I want to add slack notifications in case there is an error while running the flow. I have the lines below as part of my code:

from prefect.utilities.notifications import slack_notifier
from prefect.engine.state import Failed
SLACK_WEBHOOK_URL = "the slack secret webhook url"
# os.environ["PREFECT__CONTEXT__SECRETS__SLACK_WEBHOOK_URL"] = "<https://hooks.slack.com/services/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>"
handler = slack_notifier(only_states=[Failed])
prefect.context.setdefault("secrets", {})
prefect.context.secrets["SLACK_WEBHOOK_URL"] = "the slack secret webhook url"

I have even created config.toml file in .predict directory with the content below:

[context.secrets]
SLACK_WEBHOOK_URL = "the slack secret webhook url"

My task stats with:

@task(nout=2, max_retries=1, retry_delay=timedelta(seconds=1), checkpoint=False, state_handlers=[handler])

I also tried to add prefect app to slack. But when running my flows I am seeing this error (part of the error): see thread To make it clear, when I remove the

state_handlers=[handler]

from my task definition the flow runs fine. When I visit the prefect app in slack I see this too, which I am not sure if it connected to my problem or not. Any comments on how I can solve the slack notification problem?

hi, is it possible to trigger a run of an old version of a flow? this would be useful for us in an ml ops scenario where we need full reproducibility

@Marvin I am running a worker on kubernetes and calling a dbt cloud job. It reliably gives this error after one hour.

Error occurred while streaming logs - Job will continue to run but logs will no longer be streamed to stdout.
Traceback (most recent call last):
  File "/usr/local/lib/python3.11/site-packages/aiohttp/client_proto.py", line 92, in connection_lost
    uncompleted = self._parser.feed_eof()
                  ^^^^^^^^^^^^^^^^^^^^^^^
  File "aiohttp/_http_parser.pyx", line 508, in aiohttp._http_parser.HttpParser.feed_eof
aiohttp.http_exceptions.TransferEncodingError: 400, message:
  Not enough data for satisfy transfer length header.

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/usr/local/lib/python3.11/site-packages/prefect_kubernetes/worker.py", line 1041, in _stream_job_logs
    async for line in logs.content:
  File "/usr/local/lib/python3.11/site-packages/aiohttp/streams.py", line 52, in __anext__
    rv = await self.read_func()
         ^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.11/site-packages/aiohttp/streams.py", line 352, in readline
    return await self.readuntil()
           ^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.11/site-packages/aiohttp/streams.py", line 386, in readuntil
    await self._wait("readuntil")
  File "/usr/local/lib/python3.11/site-packages/aiohttp/streams.py", line 347, in _wait
    await waiter
aiohttp.client_exceptions.ClientPayloadError: Response payload is not completed: <TransferEncodingError: 400, message='Not enough data for satisfy transfer length header.'>

prefect.server.utilities.messaging.memory - Message failed after 4 retries and will be moved to the dead letter queue02/04 115702 what is this about?