See <https://builds.apache.org/job/beam_PreCommit_PythonLint_Cron/749/display/redirect?page=changes>
Changes: [github] add missing bracket [github] Update environments.py to add a method to specify container image [kcweaver] Moving to 2.22.0-SNAPSHOT on master branch. ------------------------------------------ [...truncated 69.21 KB...] apache_beam/transforms/environments.py:255: error: Name 'from_container_image' is not defined [name-defined] 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:665: 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:429: error: "PartitionableBuffer" has no attribute "cleared" [attr-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:441: error: "PartitionableBuffer" has no attribute "clear" [attr-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:448: error: Name 'PartitionableBuffer' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:512: error: Need more than 3 values to unpack (4 expected) [misc] apache_beam/runners/portability/fn_api_runner/fn_runner.py:519: error: Cannot determine type of 'data_side_input' [has-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:527: error: Cannot determine type of 'data_input' [has-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:528: error: Cannot determine type of 'data_output' [has-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:529: error: Cannot determine type of 'expected_timer_output' [has-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:542: error: Cannot determine type of 'data_input' [has-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:543: error: Cannot determine type of 'data_output' [has-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:545: error: Cannot determine type of 'expected_timer_output' [has-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:548: error: Cannot determine type of 'data_input' [has-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:556: error: Name 'PartitionableBuffer' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:557: 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:576: error: Cannot determine type of 'data_input' [has-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:585: error: Cannot determine type of 'data_output' [has-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:585: error: Cannot determine type of 'expected_timer_output' [has-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:599: error: Name 'PartitionableBuffer' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:619: error: Name 'PartitionableBuffer' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:623: error: Invalid type comment or annotation [valid-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:623: note: Suggestion: use Tuple[...] instead of Tuple(...) apache_beam/runners/portability/fn_api_runner/fn_runner.py:664: error: Incompatible types in assignment (expression has type "bytes", target has type "str") [assignment] apache_beam/runners/portability/fn_api_runner/fn_runner.py:665: 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:766: error: Name 'WorkerHandler' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:767: error: Name 'PartitionableBuffer' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:790: error: Name 'WorkerHandler' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:815: error: Name 'ControlFuture' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:846: error: Name 'PartitionableBuffer' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:908: error: Name 'PartitionableBuffer' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:910: error: Name 'PartitionableBuffer' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:970: error: Argument 1 has incompatible type "Dict[str, str]"; expected "bytes" [arg-type] apache_beam/runners/portability/fn_api_runner/fn_runner.py:971: 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:998: error: Name 'WorkerHandler' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:999: error: Name 'PartitionableBuffer' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:1017: 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:1018: error: Name 'PartitionableBuffer' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:1020: error: Name 'PartitionableBuffer' is not defined [name-defined] apache_beam/runners/portability/fn_api_runner/fn_runner.py:1045: 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:1073: 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:108: error: Argument 2 to "run" of "JobServiceHandle" has incompatible type "Optional[Any]"; expected "str" [arg-type] apache_beam/runners/portability/portable_runner.py:308: error: Incompatible types in assignment (expression has type "ExternalJobServer", variable has type "EmbeddedJobServer") [assignment] apache_beam/runners/portability/portable_runner.py:310: 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:714: error: Need type annotation for 'create_accumulator' [var-annotated] apache_beam/transforms/trigger_test.py:716: 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 219 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) 803.55user 17.97system 2:05.92elapsed 652%CPU (0avgtext+0avgdata 513268maxresident)k 3768inputs+264outputs (0major+1295134minor)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 :) FAILURE: Build completed with 2 failures. 1: Task failed with an exception. ----------- * What went wrong: Execution failed for task ':sdks:python:test-suites:tox:py2:lintPy27'. > 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. ============================================================================== 2: Task 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 3m 58s 8 actionable tasks: 8 executed Publishing build scan... https://gradle.com/s/orqagdc3fpn3c 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]
