chore: unpin graphql-core

Author: rexledesma

python_modules/dagit/dagit/format_error.py

@@ -1,6 +1,6 @@
 from typing import Any, Dict
 
-from graphql.error.base import GraphQLError
+from graphql.error import GraphQLError
 
 from dagster.utils.log import get_stack_trace_array
 

python_modules/dagit/dagit/graphql.py

@@ -9,7 +9,7 @@
 from graphql.error import format_error as format_graphql_error
 from graphql.execution import ExecutionResult
 from rx import Observable
-from rx.concurrency import thread_pool_scheduler
+from rx.scheduler import ThreadPoolScheduler
 from starlette import status
 from starlette.applications import Starlette
 from starlette.concurrency import run_in_threadpool
@@ -300,6 +300,7 @@ def _disposable_and_async_gen_from_obs(obs: Observable, loop):
     queue: Queue = Queue()
 
     # process observable in a thread, handle results in aio loop
+    thread_pool_scheduler = ThreadPoolScheduler()
     disposable = obs.subscribe_on(thread_pool_scheduler).subscribe(
         on_next=lambda i: loop.call_soon_threadsafe(queue.put_nowait, i)
     )

python_modules/dagster-graphql/dagster_graphql/cli.py

@@ -2,9 +2,7 @@
 
 import click
 import requests
-from graphql import graphql
-from graphql.execution.executors.gevent import GeventExecutor
-from graphql.execution.executors.sync import SyncExecutor
+from graphql import graphql_sync
 
 from dagster import __version__ as dagster_version
 from dagster import check, seven
@@ -27,26 +25,22 @@ def create_dagster_graphql_cli():
     return ui
 
 
-def execute_query(workspace_process_context, query, variables=None, use_sync_executor=False):
+def execute_query(workspace_process_context, query, variables=None):
     check.inst_param(
         workspace_process_context, "workspace_process_context", WorkspaceProcessContext
     )
     check.str_param(query, "query")
     check.opt_dict_param(variables, "variables")
-    check.bool_param(use_sync_executor, "use_sync_executor")
 
     query = query.strip("'\" \n\t")
 
     context = workspace_process_context.create_request_context()
 
-    executor = SyncExecutor() if use_sync_executor else GeventExecutor()
-
-    result = graphql(
-        request_string=query,
+    result = graphql_sync(
         schema=create_schema(),
+        source=query,
         context_value=context,
         variable_values=variables,
-        executor=executor,
     )
 
     result_dict = result.to_dict()

python_modules/dagster-graphql/dagster_graphql/implementation/execution/__init__.py

@@ -1,6 +1,6 @@
 import sys
 
-from graphql.execution.base import ResolveInfo
+from graphene import ResolveInfo
 from rx import Observable
 
 from dagster import check

python_modules/dagster-graphql/dagster_graphql/implementation/execution/launch_execution.py

@@ -1,4 +1,4 @@
-from graphql.execution.base import ResolveInfo
+from graphene import ResolveInfo
 
 from dagster import check
 from dagster.core.storage.pipeline_run import RunsFilter

python_modules/dagster-graphql/dagster_graphql/implementation/execution/run_lifecycle.py

@@ -1,4 +1,4 @@
-from graphql.execution.base import ResolveInfo
+from graphene import ResolveInfo
 
 from dagster import check
 from dagster.core.execution.plan.resume_retry import get_retry_steps_from_parent_run

python_modules/dagster-graphql/dagster_graphql/implementation/external.py

@@ -1,6 +1,6 @@
 import sys
 
-from graphql.execution.base import ResolveInfo
+from graphene import ResolveInfo
 
 from dagster import check
 from dagster.config.validate import validate_config_from_snap

python_modules/dagster-graphql/dagster_graphql/implementation/fetch_partition_sets.py

@@ -1,5 +1,5 @@
 import yaml
-from graphql.execution.base import ResolveInfo
+from graphene import ResolveInfo
 
 from dagster import check
 from dagster.core.host_representation import (

python_modules/dagster-graphql/dagster_graphql/implementation/fetch_pipelines.py

@@ -1,4 +1,4 @@
-from graphql.execution.base import ResolveInfo
+from graphene import ResolveInfo
 
 from dagster import check
 from dagster.core.storage.pipeline_run import PipelineRun

python_modules/dagster-graphql/dagster_graphql/implementation/fetch_runs.py

@@ -1,7 +1,7 @@
 from collections import defaultdict
 from typing import Dict, List
 
-from graphql.execution.base import ResolveInfo
+from graphene import ResolveInfo
 
 from dagster import PipelineDefinition, PipelineRunStatus, check
 from dagster.config.validate import validate_config