requests.exceptions.ConnectionError: HTTPConnectionPool(host='127.0.0.1', port=4200): Max retries exceeded with url: /graphql (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f1911c36d90>: Failed to establish a new connection: [Errno 111] Connection refused'))

host_ip = "my.ip.goes.here"
host_port = "4200"
host = "http://${server.host_ip}"
port = "4200"
endpoint = "${server.host}:${server.port}"
  [server.ui]
  apollo_url = "<http://my.ip.goes.here:4200/graphql>"
[cloud]
api = "${${backend}.endpoint}"
endpoint = "<https://api.prefect.io>"
graphql = "${cloud.api}/graphql"

apiVersion: batch/v1
kind: Job
metadata:
  name: prefect-job
  labels: {}
spec:
  template:
    metadata:
      labels: {}
    spec:
      containers:
        - name: flow
          image: prefecthq/prefect:latest
          imagePullPolicy: IfNotPresent
          ...
          volumeMounts:
            - name: filesystem-dir
              mountPath: /job-files
      volumes:
        - name: filesystem-dir
          hostPath:
            # directory location on host
            path: /path/to/my/dir
            # this field is optional
            type: Directory

Do mapped tasks run concurrently? Or does concurrency only happen when a dask executor is used?

comparable_items_df['tag_rank'] = comparable_items_df.groupby(['id', 'tag_name']).cumcount()

TypeError: unhashable type: 'ResultSet'

@task

Inspecting flow runs

from prefect.backend import FlowRunView

flow_run = FlowRunView.from_flow_run_id("4c0101af-c6bb-4b96-8661-63a5bbfb5596")

flow.register(«myProject»)

server.endpoint

set_temporary_config({"server.endpoint": "123"})

with case

: No heartbeat detected from the remote task;

Question for the Community - I am trying to use Prefect to schedule and monitor a Dbt project/pipeline.   I follow example and pass in dbt_kwargs for connecting to snowflake.  My dbt project runs fine with dbt run or dbt compile command, but the DbtShellTask fails - yet does not provide any reason for error.  Anywhere more detailed logging is recorded??  

Sample tasks like the hello one included here, run OK.   I'm using Studio Code to debug this code, but also try to run it in Python IDLE and get same error output     I'm running this:

from prefect import task, Flow, Parameter
from prefect.tasks.shell import ShellTask
from prefect.tasks.dbt import DbtShellTask

@task(log_stdout=True)
def say_hi(name):
    print("hello {}!".format(name))

with Flow(name="dbt_flow") as f:
    name = Parameter('name')
    say_hi(name)

    task = DbtShellTask(
        profile_name='default',
        environment='dev',
        dbt_kwargs={
            'type': 'snowflake',
            'threads': 4,
            'account': 'mysnowflake.account',
            'user': '<mailto:myemal@myco.com|myemal@myco.com>',
            'authenticator': 'externalbrowser',
            'role': 'ROLENAME',
            'database': 'DBNAME',
            'warehouse': 'ENGINEERING_XS',
            'schema': 'DV_PROTO'
        },
        overwrite_profiles=False,
        profiles_dir='C:\\Users\myDBTuser\.dbt'
    )(command='dbt compile')

out = f.run(name='Paul') 

[2022-03-07 17:18:07+0000] INFO - prefect.TaskRunner | Task 'DbtShellTask': Starting task run...
[2022-03-07 17:18:07+0000] ERROR - prefect.DbtShellTask | Command failed with exit code 1
[2022-03-07 17:18:07+0000] INFO - prefect.TaskRunner | FAIL signal raised: FAIL('Command failed with exit code 1')
[2022-03-07 17:18:07+0000] INFO - prefect.TaskRunner | Task 'DbtShellTask': Finished task run for task with final state: 'Failed'
[2022-03-07 17:18:07+0000] INFO - prefect.TaskRunner | Task 'say_hi': Starting task run...
[2022-03-07 17:18:07+0000] INFO - prefect.TaskRunner | hello Paul!
[2022-03-07 17:18:07+0000] INFO - prefect.TaskRunner | Task 'say_hi': Finished task run for task with final state: 'Success'

...venv/lib/python3.8/site-packages/prefect/client/client.py:848: UserWarning: A flow with the same name is already contained in storage; if you changed your Flow since the last build, you might experience unexpected issues and should re-create your storage object.

flow.storage = Docker(....)

flow_run.duration

flow_run

prefecthq/prefect:1.0.0

in get_flow
  from github import UnknownObjectException
ModuleNotFoundError: No module named 'github'

checkpointing

Result

TypeError: StartFlowRun.run() missing 1 required positional argument: 'self'

flow.run()