#prefect_test.py
import prefect
from prefect import task, Flow

@task
def hello_task():
    logger = prefect.context.get("logger")
    <http://logger.info|logger.info>("Hello, Cloud!")

flow = Flow("hello-flow", tasks=[hello_task])
flow.register()
flow.run_agent()

prefect server start --hasura-port=3050

<http://localhost:8080/flow/6e437b8f-9fc2-41c1-9862-311d9a423442>

create_cloud_hook

{
  "graphQLErrors": [
    {
      "path": [
        "create_cloud_hook"
      ],
      "message": "Expected type JSON, found {to: \"<mailto:test@test.com|test@test.com>\"}; 'ObjectValueNode' object has no attribute 'value'",
      "extensions": {
        "code": "INTERNAL_SERVER_ERROR",
        "exception": {
          "message": "Expected type JSON, found {to: \"<mailto:test@test.com|test@test.com>\"}; 'ObjectValueNode' object has no attribute 'value'",
          "locations": [
            {
              "line": 2,
              "column": 146
            }
          ],
          "path": null
        }
      }
    }
  ],
  "networkError": null,
  "message": "GraphQL error: Expected type JSON, found {to: \"<mailto:test@test.com|test@test.com>\"}; 'ObjectValueNode' object has no attribute 'value'"
}

CreateContainer(image_name='vgg', 
                detach=True, 
                ports={'5000/tcp': 5050}, 
                name=container_name,
                )

ERROR - prefect.TaskRunner | Unexpected error: TypeError("__init__() got an unexpected keyword argument 'ports'",)

Is there any way to write a custom Storage class that extends one of the Prefect built-in Storage classes?

0.12.0

No value for argument 'fn' in function callpylint(no-value-for-parameter)

@task(name="Something")

docker_server_url

DockerException("Error while fetching server API version: ('Connection aborted.', FileNotFoundError(2, 'No such file or directory'))",)

containers.py

Failed to set task state with error: ClientError([{'path': ['set_task_run_states'], 'message': 'State update failed for task run ID a8c171e6-49fc-4370-90ee-ae9319f5848a: provided a running state but associated flow run 5ab28d3b-0dad-4327-8063-f019e5cbbdd5 is not in a running state.', 'extensions': {'code': 'INTERNAL_SERVER_ERROR'}}])
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/prefect/engine/cloud/task_runner.py", line 119, in call_runner_target_handlers
    cache_for=self.task.cache_for,
  File "/usr/local/lib/python3.7/site-packages/prefect/client/client.py", line 1085, in set_task_run_state
    version=version,
  File "/usr/local/lib/python3.7/site-packages/prefect/client/client.py", line 225, in graphql
    raise ClientError(result["errors"])
prefect.utilities.exceptions.ClientError: [{'path': ['set_task_run_states'], 'message': 'State update failed for task run ID a8c171e6-49fc-4370-90ee-ae9319f5848a: provided a running state but associated flow run 5ab28d3b-0dad-4327-8063-f019e5cbbdd5 is not in a running state.', 'extensions': {'code': 'INTERNAL_SERVER_ERROR'}}]

Task 'DQ Test - postgres extractions and test creation[40]': unexpected error while running task: FileNotFoundError(2, 'No such file or directory')
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/prefect/engine/task_runner.py", line 271, in run
    state=state, upstream_states=upstream_states
  File "/usr/local/lib/python3.7/site-packages/prefect/engine/task_runner.py", line 590, in get_task_inputs
    handler
  File "/usr/local/lib/python3.7/site-packages/prefect/engine/result/base.py", line 294, in to_result
    value = self.result_handler.read(self.value)
  File "/usr/local/lib/python3.7/site-packages/prefect/engine/result_handlers/local_result_handler.py", line 62, in read
    with open(fpath, "rb") as f:
FileNotFoundError: [Errno 2] No such file or directory: '/src/prefect-result-2020-06-22t04-16-48-214966-00-00'

flow.run()

get_logger()

logger = logging.getLogger(__name___)_

flow.run()

logging.getLogger

get_logger