See <https://builds.apache.org/job/beam_PreCommit_PythonLint_Cron/760/display/redirect>
Changes: ------------------------------------------ [...truncated 68.77 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) 875.08user 18.87system 2:16.49elapsed 654%CPU (0avgtext+0avgdata 522520maxresident)k 0inputs+264outputs (0major+1413828minor)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 4m 20s 8 actionable tasks: 8 executed Publishing build scan... https://gradle.com/s/sjm7rer2a2by2 Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
