You are viewing a plain text version of this content. The canonical link for it is here.

Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2020/04/11 06:36:15 UTC

Build failed in Jenkins: beam_PreCommit_PythonLint_Cron #753

See <https://builds.apache.org/job/beam_PreCommit_PythonLint_Cron/753/display/redirect?page=changes>

Changes:

[ankurgoenka] TOIL: Update Unified worker image


------------------------------------------
[...truncated 69.63 KB...]
apache_beam/pvalue.py:360: error: Cannot determine type of 'windowfn'  [has-type]
apache_beam/transforms/userstate.py:160: error: Type signature has too few arguments  [syntax]
apache_beam/runners/worker/data_plane.py:306: error: Incompatible default for argument "unused_expected_inputs" (default has type "None", argument has type "Collection[str]")  [assignment]
apache_beam/runners/worker/data_plane.py:591: error: Unsupported dynamic base class "with_metaclass"  [misc]
apache_beam/runners/worker/data_plane.py:592: error: unused 'type: ignore' comment
apache_beam/transforms/ptransform.py:666: error: Type signature has too few arguments  [syntax]
apache_beam/transforms/core.py:1343: error: Type signature has too few arguments  [syntax]
apache_beam/transforms/core.py:2559: error: Type signature has too few arguments  [syntax]
apache_beam/io/iobase.py:1302: error: Missing return statement  [return]
apache_beam/io/iobase.py:1310: error: Missing return statement  [return]
apache_beam/transforms/environments.py:193: error: Too many arguments  [call-arg]
apache_beam/transforms/environments.py:196: error: Argument 3 has incompatible type "RepeatedCompositeFieldContainer[ArtifactInformation]"; expected "PipelineContext"  [arg-type]
apache_beam/transforms/environments.py:259: error: Type signature has too few arguments  [syntax]
apache_beam/runners/pipeline_context.py:121: error: Type signature has too few arguments  [syntax]
apache_beam/runners/portability/stager.py:149: error: Name 'Tuple' is not defined  [name-defined]
apache_beam/runners/portability/stager.py:149: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Tuple")
apache_beam/runners/portability/stager.py:278: error: Name 'Tuple' is not defined  [name-defined]
apache_beam/runners/portability/stager.py:278: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Tuple")
apache_beam/runners/portability/stager.py:392: error: Name 'Tuple' is not defined  [name-defined]
apache_beam/runners/portability/stager.py:392: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Tuple")
apache_beam/runners/portability/stager.py:408: error: Name 'Tuple' is not defined  [name-defined]
apache_beam/runners/portability/stager.py:408: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Tuple")
apache_beam/runners/portability/stager.py:443: error: Name 'Tuple' is not defined  [name-defined]
apache_beam/runners/portability/stager.py:443: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Tuple")
apache_beam/runners/portability/stager.py:465: error: Name 'Tuple' is not defined  [name-defined]
apache_beam/runners/portability/stager.py:465: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Tuple")
apache_beam/runners/portability/stager.py:604: error: Name 'Tuple' is not defined  [name-defined]
apache_beam/runners/portability/stager.py:604: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Tuple")
apache_beam/transforms/util.py:664: error: All conditional function variants must have identical signatures  [misc]
apache_beam/runners/common.py:494: error: "OutputProcessor" has no attribute "start_bundle_outputs"  [attr-defined]
apache_beam/runners/common.py:502: error: "OutputProcessor" has no attribute "finish_bundle_outputs"  [attr-defined]
apache_beam/runners/common.py:701: error: Argument 1 to "ThreadsafeWatermarkEstimator" has incompatible type "Optional[Any]"; expected "WatermarkEstimator"  [arg-type]
apache_beam/runners/common.py:826: error: Item "None" of "Optional[ThreadsafeWatermarkEstimator]" has no attribute "current_watermark"  [union-attr]
apache_beam/runners/common.py:828: error: Item "None" of "Optional[ThreadsafeWatermarkEstimator]" has no attribute "get_estimator_state"  [union-attr]
apache_beam/runners/common.py:845: error: Item "None" of "Optional[ThreadsafeWatermarkEstimator]" has no attribute "current_watermark"  [union-attr]
apache_beam/runners/common.py:847: error: Item "None" of "Optional[ThreadsafeWatermarkEstimator]" has no attribute "get_estimator_state"  [union-attr]
apache_beam/runners/dataflow/dataflow_runner.py:256: error: Name 'Iterable' is not defined  [name-defined]
apache_beam/runners/dataflow/dataflow_runner.py:256: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Iterable")
apache_beam/runners/dataflow/dataflow_runner.py:256: error: Name 'T' is not defined  [name-defined]
apache_beam/pipeline.py:430: error: Incompatible types in assignment (expression has type "List[PValue]", target has type "Sequence[Union[PBegin, PCollection[Any]]]")  [assignment]
apache_beam/pipeline.py:436: error: Incompatible types in assignment (expression has type "PValue", variable has type "PCollection[Any]")  [assignment]
apache_beam/pipeline.py:827: error: Item "None" of "Optional[AppliedPTransform]" has no attribute "full_label"  [union-attr]
apache_beam/pipeline.py:937: error: Incompatible default for argument "input_tags_to_preserve" (default has type "None", argument has type "Dict[PCollection[Any], str]")  [assignment]
apache_beam/pipeline.py:1124: error: Function is missing a type annotation  [no-untyped-def]
apache_beam/pipeline.py:1165: error: Incompatible types in assignment (expression has type "None", variable has type "ParDoPayload")  [assignment]
apache_beam/pipeline.py:1176: error: Incompatible return value type (got "Optional[Match[str]]", expected "bool")  [return-value]
apache_beam/pipeline.py:1211: error: Argument 1 to "append" of "list" has incompatible type "AsIter"; expected "AsMultiMap"  [arg-type]
apache_beam/pipeline.py:1255: error: Item "RunnerAPIPTransformHolder" of "Union[ParDo, RunnerAPIPTransformHolder]" has no attribute "output_tags"  [union-attr]
apache_beam/pipeline.py:1266: error: Unsupported dynamic base class "with_metaclass"  [misc]
apache_beam/pipeline.py:1267: error: unused 'type: ignore' comment
apache_beam/runners/portability/artifact_service.py:331: error: Syntax error in type annotation  [syntax]
apache_beam/runners/portability/artifact_service.py:331: note: Suggestion: Is there a spurious trailing comma?
apache_beam/runners/portability/artifact_service.py:372: error: Name 'Optional' is not defined  [name-defined]
apache_beam/runners/portability/artifact_service.py:372: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Optional")
apache_beam/runners/portability/artifact_service.py:372: error: Name 'Tuple' is not defined  [name-defined]
apache_beam/runners/portability/artifact_service.py:372: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Tuple")
apache_beam/runners/portability/artifact_service.py:375: error: Need type annotation for '_jobs_to_stage' (hint: "_jobs_to_stage: Dict[<type>, <type>] = ...")  [var-annotated]
apache_beam/runners/portability/artifact_service.py:381: error: Name 'Any' is not defined  [name-defined]
apache_beam/runners/portability/artifact_service.py:381: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Any")
apache_beam/runners/portability/artifact_service.py:381: error: Name 'List' is not defined  [name-defined]
apache_beam/runners/portability/artifact_service.py:381: note: Did you forget to import it from "typing"? (Suggestion: "from typing import List")
apache_beam/runners/interactive/caching/streaming_cache.py:48: error: Name 'Path' already defined (possibly by an import)  [no-redef]
apache_beam/runners/direct/test_stream_impl.py:53: error: Incompatible types in assignment (expression has type "None", variable has type Module)  [assignment]
apache_beam/runners/worker/bundle_processor.py:152: error: "ClosableOutputStream" has no attribute "maybe_flush"  [attr-defined]
apache_beam/runners/worker/bundle_processor.py:219: error: Signature of "try_split" incompatible with supertype "Operation"  [override]
apache_beam/runners/worker/bundle_processor.py:602: error: Argument 1 to "encode_to_stream" of "TimerCoderImpl" has incompatible type "Timer"; expected "Dict[Any, Any]"  [arg-type]
apache_beam/runners/worker/bundle_processor.py:603: error: "ClosableOutputStream" has no attribute "maybe_flush"  [attr-defined]
apache_beam/runners/worker/bundle_processor.py:639: error: Need type annotation for '_timers_info' (hint: "_timers_info: Dict[<type>, <type>] = ...")  [var-annotated]
apache_beam/runners/worker/bundle_processor.py:715: error: Need type annotation for '_timer_output_streams' (hint: "_timer_output_streams: Dict[<type>, <type>] = ...")  [var-annotated]
apache_beam/runners/worker/bundle_processor.py:716: error: Need type annotation for '_timer_coders_impl' (hint: "_timer_coders_impl: Dict[<type>, <type>] = ...")  [var-annotated]
apache_beam/runners/worker/bundle_processor.py:774: error: Need type annotation for 'timers_info' (hint: "timers_info: Dict[<type>, <type>] = ...")  [var-annotated]
apache_beam/runners/worker/bundle_processor.py:897: error: "Operation" has no attribute "add_timer_info"  [attr-defined]
apache_beam/runners/worker/bundle_processor.py:900: error: Incompatible types in assignment (expression has type "List[str]", variable has type "List[DataInputOperation]")  [assignment]
apache_beam/runners/worker/bundle_processor.py:902: error: Argument 2 to "input_elements" of "_GrpcDataChannel" has incompatible type "List[DataInputOperation]"; expected "Collection[Union[str, Tuple[str, str]]]"  [arg-type]
apache_beam/runners/worker/bundle_processor.py:909: error: "Operation" has no attribute "process_timer"  [attr-defined]
apache_beam/runners/worker/bundle_processor.py:1015: error: 'None' object is not iterable  [misc]
apache_beam/runners/worker/bundle_processor.py:1500: error: Argument 5 to "StateBackedSideInputMap" has incompatible type "Coder"; expected "WindowedValueCoder"  [arg-type]
apache_beam/runners/worker/bundle_processor.py:1533: error: Incompatible types in assignment (expression has type "Coder", variable has type "Optional[WindowedValueCoder]")  [assignment]
apache_beam/runners/worker/sdk_worker.py:166: error: Cannot infer type of lambda  [misc]
apache_beam/runners/worker/sdk_worker.py:166: error: Argument 1 to "KeyedDefaultDict" has incompatible type "Callable[[Any], Any]"; expected "Optional[Callable[[], Any]]"  [arg-type]
apache_beam/runners/worker/sdk_worker.py:356: error: Unsupported target for indexed assignment  [index]
apache_beam/runners/worker/sdk_worker.py:595: error: Argument "process_bundle_progress" to "InstructionResponse" has incompatible type "ProcessBundleProgressMetadataResponse"; expected "Optional[ProcessBundleProgressResponse]"  [arg-type]
apache_beam/runners/worker/sdk_worker.py:597: error: Argument "monitoring_info" to "ProcessBundleProgressMetadataResponse" has incompatible type "List[MonitoringInfo]"; expected "Optional[Mapping[str, Any]]"  [arg-type]
apache_beam/runners/worker/sdk_worker.py:658: error: Unsupported dynamic base class "with_metaclass"  [misc]
apache_beam/runners/worker/sdk_worker.py:659: error: unused 'type: ignore' comment
apache_beam/runners/portability/fn_api_runner/translations.py:278: error: Invalid index type "Optional[str]" for "MutableMapping[str, Environment]"; expected type "str"  [index]
apache_beam/runners/portability/fn_api_runner/translations.py:337: error: Need type annotation for 'data_channel_coders' (hint: "data_channel_coders: Dict[<type>, <type>] = ...")  [var-annotated]
apache_beam/runners/direct/transform_evaluator.py:717: error: Argument 1 to "PBegin" has incompatible type "Optional[Pipeline]"; expected "Pipeline"  [arg-type]
apache_beam/runners/portability/fn_api_runner/execution.py:53: error: Name 'Iterator' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:53: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Iterator")
apache_beam/runners/portability/fn_api_runner/execution.py:63: error: Name 'List' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:63: note: Did you forget to import it from "typing"? (Suggestion: "from typing import List")
apache_beam/runners/portability/fn_api_runner/execution.py:84: error: Name 'List' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:84: note: Did you forget to import it from "typing"? (Suggestion: "from typing import List")
apache_beam/runners/portability/fn_api_runner/execution.py:106: error: Name 'Iterator' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:106: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Iterator")
apache_beam/runners/portability/fn_api_runner/execution.py:130: error: Name 'DefaultDict' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:133: error: Name 'Optional' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:133: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Optional")
apache_beam/runners/portability/fn_api_runner/execution.py:152: error: Name 'List' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:152: note: Did you forget to import it from "typing"? (Suggestion: "from typing import List")
apache_beam/runners/portability/fn_api_runner/execution.py:192: error: Name 'Iterator' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:192: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Iterator")
apache_beam/runners/portability/fn_api_runner/execution.py:224: error: Name 'DefaultDict' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:231: error: Name 'WindowedValueCoderImpl' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:239: error: Name 'Iterator' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:239: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Iterator")
apache_beam/runners/portability/fn_api_runner/execution.py:239: error: Name 'Tuple' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/execution.py:239: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Tuple")
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:79: error: Name 'message' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:81: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:172: error: Need type annotation for '_req_sent'  [var-annotated]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:173: error: Need type annotation for '_req_worker_mapping' (hint: "_req_worker_mapping: Dict[<type>, <type>] = ...")  [var-annotated]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:244: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:289: error: Name 'T' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:289: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:293: error: Name 'Type' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:293: error: Name 'T' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:306: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:318: error: Argument 1 has incompatible type "Type[EmbeddedWorkerHandler]"; expected "Callable[[Any, StateServicer, Optional[Any], GrpcServer], WorkerHandler]"  [arg-type]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:325: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:411: error: Item "None" of "Optional[ProvisionInfo]" has no attribute "logging_endpoint"  [union-attr]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:412: error: Item "None" of "Optional[ProvisionInfo]" has no attribute "artifact_endpoint"  [union-attr]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:413: error: Item "None" of "Optional[ProvisionInfo]" has no attribute "control_endpoint"  [union-attr]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:434: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:523: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:586: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:629: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:669: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:697: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:770: error: Name 'ExtendedProvisionInfo' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:780: error: Need type annotation for '_process_bundle_descriptors' (hint: "_process_bundle_descriptors: Dict[<type>, <type>] = ...")  [var-annotated]
apache_beam/runners/portability/fn_api_runner/worker_handlers.py:818: error: Item "None" of "Optional[Any]" has no attribute "for_environment"  [union-attr]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:434: error: "PartitionableBuffer" has no attribute "cleared"  [attr-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:446: error: "PartitionableBuffer" has no attribute "clear"  [attr-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:453: error: Name 'PartitionableBuffer' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:517: error: Need more than 3 values to unpack (4 expected)  [misc]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:524: error: Cannot determine type of 'data_side_input'  [has-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:532: error: Cannot determine type of 'data_input'  [has-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:533: error: Cannot determine type of 'data_output'  [has-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:534: error: Cannot determine type of 'expected_timer_output'  [has-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:547: error: Cannot determine type of 'data_input'  [has-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:548: error: Cannot determine type of 'data_output'  [has-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:550: error: Cannot determine type of 'expected_timer_output'  [has-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:553: error: Cannot determine type of 'data_input'  [has-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:561: error: Name 'PartitionableBuffer' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:562: error: Need type annotation for 'fired_timers' (hint: "fired_timers: Dict[<type>, <type>] = ...")  [var-annotated]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:581: error: Cannot determine type of 'data_input'  [has-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:590: error: Cannot determine type of 'data_output'  [has-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:590: error: Cannot determine type of 'expected_timer_output'  [has-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:604: error: Name 'PartitionableBuffer' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:624: error: Name 'PartitionableBuffer' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:628: error: Invalid type comment or annotation  [valid-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:628: note: Suggestion: use Tuple[...] instead of Tuple(...)
apache_beam/runners/portability/fn_api_runner/fn_runner.py:669: error: Incompatible types in assignment (expression has type "bytes", target has type "str")  [assignment]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:670: error: Incompatible return value type (got "Tuple[Dict[str, Any], Dict[Tuple[str, str], Tuple[bytes, FunctionSpec]], Dict[str, bytes], Dict[Any, str]]", expected "Tuple[Dict[str, Any], Dict[Tuple[str, str], Tuple[bytes, FunctionSpec]], Dict[str, bytes]]")  [return-value]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:771: error: Name 'WorkerHandler' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:772: error: Name 'PartitionableBuffer' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:795: error: Name 'WorkerHandler' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:820: error: Name 'ControlFuture' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:851: error: Name 'PartitionableBuffer' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:913: error: Name 'PartitionableBuffer' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:915: error: Name 'PartitionableBuffer' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:975: error: Argument 1 has incompatible type "Dict[str, str]"; expected "bytes"  [arg-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:976: error: Invalid index type "Tuple[str, str]" for "Dict[str, Dict[str, str]]"; expected type "str"  [index]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:1003: error: Name 'WorkerHandler' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:1004: error: Name 'PartitionableBuffer' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:1022: error: Argument 4 of "process_bundle" is incompatible with supertype "BundleManager"; supertype defines the argument type as "Dict[str, Dict[str, str]]"  [override]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:1023: error: Name 'PartitionableBuffer' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:1025: error: Name 'PartitionableBuffer' is not defined  [name-defined]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:1050: error: Argument 4 to "process_bundle" of "BundleManager" has incompatible type "Dict[Tuple[str, str], str]"; expected "Dict[str, Dict[str, str]]"  [arg-type]
apache_beam/runners/portability/fn_api_runner/fn_runner.py:1078: error: Name 'WorkerHandler' is not defined  [name-defined]
apache_beam/runners/interactive/interactive_beam.py:265: error: Name 'Union' is not defined  [name-defined]
apache_beam/runners/interactive/interactive_beam.py:265: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Union")
apache_beam/runners/interactive/interactive_beam.py:265: error: Name 'Dict' is not defined  [name-defined]
apache_beam/runners/interactive/interactive_beam.py:265: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Dict")
apache_beam/runners/interactive/interactive_beam.py:265: error: Name 'Any' is not defined  [name-defined]
apache_beam/runners/interactive/interactive_beam.py:265: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Any")
apache_beam/runners/interactive/interactive_beam.py:265: error: Name 'PCollection' is not defined  [name-defined]
apache_beam/runners/interactive/interactive_beam.py:265: error: Name 'Iterable' is not defined  [name-defined]
apache_beam/runners/interactive/interactive_beam.py:265: note: Did you forget to import it from "typing"? (Suggestion: "from typing import Iterable")
apache_beam/runners/interactive/interactive_beam.py:325: error: Need type annotation for 'flatten_pcolls' (hint: "flatten_pcolls: List[<type>] = ...")  [var-annotated]
apache_beam/runners/interactive/interactive_beam.py:338: error: Incompatible types in assignment (expression has type "List[PCollection[Any]]", variable has type "Tuple[Any, ...]")  [assignment]
apache_beam/runners/interactive/interactive_beam.py:390: error: Incompatible types in assignment (expression has type "Set[Any]", variable has type "Tuple[Any, ...]")  [assignment]
apache_beam/runners/interactive/interactive_beam.py:395: error: "Tuple[Any, ...]" has no attribute "difference"  [attr-defined]
apache_beam/runners/portability/portable_runner.py:110: error: Argument 2 to "run" of "JobServiceHandle" has incompatible type "Optional[Any]"; expected "str"  [arg-type]
apache_beam/runners/portability/portable_runner.py:329: error: Incompatible types in assignment (expression has type "ExternalJobServer", variable has type "EmbeddedJobServer")  [assignment]
apache_beam/runners/portability/portable_runner.py:331: error: Incompatible types in assignment (expression has type "JobServer", variable has type "EmbeddedJobServer")  [assignment]
apache_beam/typehints/decorators_test_py3.py:196: error: Name 'DecoratorsTest' already defined on line 182  [no-redef]
apache_beam/runners/interactive/utils_test.py:36: error: Incompatible import of "patch" (imported name has type "mock._patcher", local name has type "unittest.mock._patcher")  [misc]
apache_beam/runners/interactive/interactive_beam_test.py:37: error: Incompatible import of "patch" (imported name has type "mock._patcher", local name has type "unittest.mock._patcher")  [misc]
apache_beam/ml/gcp/naturallanguageml.py:81: error: Dict entry 1 has incompatible type "str": "Optional[str]"; expected "str": "str"  [dict-item]
apache_beam/io/gcp/datastore/v1new/types.py:251: error: Need type annotation for 'properties' (hint: "properties: Dict[<type>, <type>] = ...")  [var-annotated]
apache_beam/io/flink/flink_streaming_impulse_source.py:71: error: Argument 1 has incompatible type "Callable[[Any, Any], Any]"; expected "Union[type, Callable[[PTransform, bytes, PipelineContext], Any]]"  [arg-type]
apache_beam/typehints/typecheck_test_py3.py:39: error: Module has no attribute "_enable_from_callable"; maybe "_disable_from_callable"?  [attr-defined]
apache_beam/typehints/typecheck_test_py3.py:72: error: Return type "int" of "process" incompatible with return type "Iterable[int]" in supertype "MyDoFn"  [override]
apache_beam/typehints/typecheck_test_py3.py:74: error: Too few arguments for "process" of "MyDoFn"  [call-arg]
apache_beam/typehints/typecheck_test_py3.py:74: error: Incompatible return value type (got "Iterable[int]", expected "int")  [return-value]
apache_beam/transforms/trigger_test.py:748: error: Need type annotation for 'create_accumulator'  [var-annotated]
apache_beam/transforms/trigger_test.py:750: error: Need type annotation for 'merge_accumulators'  [var-annotated]
apache_beam/transforms/combiners_test.py:386: error: All conditional function variants must have identical signatures  [misc]
apache_beam/testing/synthetic_pipeline.py:88: error: Cannot assign multiple types to name "Generator" without an explicit "Type[...]" annotation  [misc]
apache_beam/ml/gcp/videointelligenceml_test_it.py:42: error: Cannot assign to a type  [misc]
apache_beam/ml/gcp/videointelligenceml_test_it.py:42: error: Incompatible types in assignment (expression has type "None", variable has type "Type[AnnotateVideoWithContext]")  [assignment]
apache_beam/ml/gcp/cloud_dlp_test.py:106: error: Name 'TestDeidentifyFn' already defined on line 57  [no-redef]
Found 218 errors in 44 files (checked 666 source files)
error: mypy exited with status 1
py37-mypy run-test-post: commands[0] | <https://builds.apache.org/job/beam_PreCommit_PythonLint_Cron/ws/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/scripts/run_tox_cleanup.sh>
___________________________________ summary ____________________________________
  py37-mypy: commands succeeded
  congratulations :)

> Task :sdks:python:test-suites:tox:py2:lintPy27_3

--------------------------------------------------------------------
Your code has been rated at 10.00/10 (previous run: 10.00/10, +0.00)

1374.31user 31.04system 12:07.22elapsed 193%CPU (0avgtext+0avgdata 540016maxresident)k
0inputs+264outputs (0major+1302972minor)pagefaults 0swaps
py27-lint3 run-test-post: commands[0] | <https://builds.apache.org/job/beam_PreCommit_PythonLint_Cron/ws/src/sdks/python/test-suites/tox/py2/build/srcs/sdks/python/scripts/run_tox_cleanup.sh>
___________________________________ summary ____________________________________
  py27-lint3: commands succeeded
  congratulations :)

> Task :sdks:python:test-suites:tox:py2:lint

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':sdks:python:test-suites:tox:py37:lintPy37'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with Gradle 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 20m 2s
8 actionable tasks: 8 executed

Publishing build scan...
https://gradle.com/s/la45yagppwsqe

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org