I have a task that I think returns only 1 result, but I keep getting the below error. Is there a reason why this task thinks it’s returning multiple results? (code in thread)

TypeError: Task is not iterable. If your task returns multiple results, pass `nout` to the task decorator/constructor, or provide a `Tuple` return-type annotation to your task.

Hello Prefect, I'm getting an error

TypeError: cannot pickle '_thread.lock' object

(I'll paste full error code in the comments) and I'm out of ideas how to properly solve it. It is related with

DaskExecutor

and it appears when trying to proceed this task(I'll upload code sample in the comments): 1. Read file content from a yml file which is located in the S3 storage. For file reading I'm using raw

boto3

implementation. 2. Read bytes from the downloded yml file 3. Load yml file and convert it into list Does anyone knows a solution to this problem?

@Marvin I have a k8s cluster where I have installed prefect-server and worker. For the on premise installations I won't have internet connections and so I am trying to use an internal docker registry for storing the flow code in it and pulling it at runtime by the ephimeral pod. I have problems since the internal registry on k8s requires https. What solution can you propose me?

Hi Prefect Community, I'm having issue on sending notification to Microsoft Teams using webhook block & Automation. The generic Microsoft Teams block simply won't send anything, if I switch to the Custom Webhook block, it will send only headers but no content. This is really confusing, how should i make it work? I'm currently on Ver 3.1.11

@Marvin Can you please show me an updated example of how to use run_deployment() in v3, printing the result of the deployment?

Hi guys, discovering prefect docker-work-pools, I encounter the following error when deploying a flow.

RuntimeError: This error is often thrown because Docker is not running. Please ensure Docker is running.

This is my code

from flows import hello_world

if __name__ == "__main__":
    hello_world.deploy(
        "my-second-deployment",
        work_pool_name='docker-work-pool',
        interval=300,
        image='<http://registry.gitlab.com/<git-user>/<repo-name>:latest|registry.gitlab.com/<git-user>/<repo-name>:latest>',
    )

requirements.txt

prefect==2.20.8
prefect-docker==0.5.5
requests==2.31.0

Could anyone assist me please ?

@Marvin What is clusterUid or PREFECT_KUBERNETES_CLUSTER_UID needed for? Can I just use fake value here. Currently I have issued deploying it to the cluster as the role in using doesn’t have access to live-system namespace

Hello folks, I keep getting this error when trying to run a deployment in Prefect Cloud :

Flow could not be retrieved from deployment.
Traceback (most recent call last):
  File "/usr/local/lib/python3.10/site-packages/prefect/deployments/steps/core.py", line 154, in run_steps
    step_output = await run_step(step, upstream_outputs)
  File "/usr/local/lib/python3.10/site-packages/prefect/deployments/steps/core.py", line 125, in run_step
    result = await from_async.call_soon_in_new_thread(
  File "/usr/local/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 327, in aresult
    return await asyncio.wrap_future(self.future)
  File "/usr/local/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 352, in _run_sync
    result = self.fn(*self.args, **self.kwargs)
  File "/usr/local/lib/python3.10/site-packages/prefect/utilities/asyncutils.py", line 311, in coroutine_wrapper
    return call()
  File "/usr/local/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 432, in __call__
    return self.result()
  File "/usr/local/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 318, in result
    return self.future.result(timeout=timeout)
  File "/usr/local/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 179, in result
    return self.__get_result()
  File "/usr/local/lib/python3.10/concurrent/futures/_base.py", line 403, in __get_result
    raise self._exception
  File "/usr/local/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 389, in _run_async
    result = await coro
  File "/usr/local/lib/python3.10/site-packages/prefect/deployments/steps/pull.py", line 123, in git_clone
    await storage.pull_code()
  File "/usr/local/lib/python3.10/site-packages/prefect/runner/storage.py", line 233, in pull_code
    await self._clone_repo()
  File "/usr/local/lib/python3.10/site-packages/prefect/runner/storage.py", line 241, in _clone_repo
    repository_url = self._repository_url_with_credentials
  File "/usr/local/lib/python3.10/site-packages/prefect/runner/storage.py", line 167, in _repository_url_with_credentials
    for k, v in credentials.items():
AttributeError: 'str' object has no attribute 'items'

I don't really know where the problem is coming from, as it seems to come from Prefect's modules and not something I wrote. Here is the .yaml of my deployment :

name: tenacy-prefect
prefect-version: 2.20.2

# build section allows you to manage and build docker images
build:

# push section allows you to manage if and how this project is uploaded to remote locations
push:

# pull section allows you to provide instructions for cloning this project in remote locations
pull:
- prefect.deployments.steps.git_clone:
    repository: <https://my-private-gitlab-instance.io/data/tenacy-prefect.git>
    credentials: '{{prefect.blocks.secret.gitlab-personal-token}}'


# the deployments section allows you to provide configuration for deploying flows
deployments:
- name: Younium
  version:
  tags: []
  description:
  entrypoint: flows/flows.py:younium_flow
  parameters: {}
  work_pool:
    name: tenacy-work-pool
    work_queue_name:
    job_variables: {}
  schedules: []

Hi @Marvin , I'm trying to connect Prefect with a cloud Postgres db. I created a database credentials block with all the info such host, user, password, etc. From the docs I copied a flow code to read data from a database with SELECT, but it doesn't work, the error says that it can't find a block with the name I gave it.

I'm struggling to get logs to display within flow/task runs. Here's some example code that gets executed by my worker. None of these logs are displayed.

try:
    logger = get_run_logger()
    logger.setLevel(logging.INFO)
except MissingContextError:
    # If there's no active Prefect context, use a standard Python logger
    logger = logging.getLogger()


def run_single_pipeline(account_id: str, resource: str) -> Dict:
    """Run a single pipeline for a given account and resource"""
    logger.info(f"Starting pipeline for account {account_id}, resource {resource}")
    #...pipeline code
   logger.info(f"Pipeline run successful for {account_id} - {resource}")

@task(persist_result=True)
def process_ads(account_id: str) -> Dict:
    try:
        result = run_single_pipeline(account_id, "ads")
        logger.info(f"Pipeline result for table ads: {result}")
        return result
    except PrefectException as e:
        logger.error(f"Pipeline error for table ads: {str(e)}")
        raise  # Re-raise the exception to mark the flow run as failed